0001 // 0002 // SynchronizedSubscribeType.swift 0003 // Rx 0004 // 0005 // Created by Krunoslav Zaher on 10/25/15. 0006 // Copyright © 2015 Krunoslav Zaher. All rights reserved. 0007 // 0008 0009 import Foundation 0010 0011 protocol SynchronizedSubscribeType: class, ObservableType, Lock { 0012 func _synchronized_subscribe
SynchronizedSubscribeType.swift:15 extension SynchronizedSubscribeType {<O: ObserverType where O.E == E>(observer: O) -> Disposable 0013 } 0014 0015 extension SynchronizedSubscribeType { 0016 func synchronizedSubscribe<O: ObserverType where O.E == E>(observer: O) -> Disposable { 0017 lock(); defer { unlock() } 0018 return _synchronized_subscribe(observer) 0019 } 0020 }
SynchronizedSubscribeType.swift:18 return _synchronized_subscribe(observer)