0001 // 0002 // SubjectType.swift 0003 // Rx 0004 // 0005 // Created by Krunoslav Zaher on 3/1/15. 0006 // Copyright © 2015 Krunoslav Zaher. All rights reserved. 0007 // 0008 0009 import Foundation 0010 0011 /** 0012 Represents an object that is both an observable sequence as well as an observer. 0013 */ 0014 public protocol SubjectType: ObservableType { 0015 /** 0016 The type of the observer that represents this subject. 0017 0018 Usually this type is type of subject itself, but it doesn't have to be. 0019 */ 0020 typealias SubjectObserverType
BehaviorSubject.swift:18 , SubjectTypeObservable+Binding.swift:28 public func multicast<S: SubjectType where S.SubjectObserverType.E == E>(subject: S)Observable+Binding.swift:47 public func multicast<S: SubjectType, R where S.SubjectObserverType.E == E>(subjectSelector: () throws -> S, selector: (Observable<S.E>) throws -> Observable<R>)PublishSubject.swift:18 , SubjectTypeReplaySubject.swift:18 , SubjectType: ObserverType 0021 0022 /** 0023 Returns observer interface for subject. 0024 0025 - returns: Observer interface for subject. 0026 */ 0027 func asObserver
ConnectableObservable.swift:63 private let _source: Observable<S.SubjectObserverType.E>ConnectableObservable.swift:70 init(source: Observable<S.SubjectObserverType.E>, subject: S) {Multicast.swift:56 private let _source: Observable<S.SubjectObserverType.E>Multicast.swift:60 init(source: Observable<S.SubjectObserverType.E>, subjectSelector: SubjectSelectorType, selector: SelectorType) {Observable+Binding.swift:28 public func multicast<S: SubjectType where S.SubjectObserverType.E == E>(subject: S)Observable+Binding.swift:47 public func multicast<S: SubjectType, R where S.SubjectObserverType.E == E>(subjectSelector: () throws -> S, selector: (Observable<S.E>) throws -> Observable<R>)SubjectType.swift:27 func asObserver() -> SubjectObserverType() -> SubjectObserverType 0028 }
ConnectableObservable.swift:82 let disposable = _source.subscribe(_subject.asObserver())