Back to Rxswift

AsyncSubject

docs/Classes/AsyncSubject.html

6.10.21.9 KB
Original Source

AsyncSubject

public final class AsyncSubject<Element>:
    Observable<Element>,
    SubjectType,
    ObserverType,
    SynchronizedUnsubscribeType

An AsyncSubject emits the last value (and only the last value) emitted by the source Observable, and only after that source Observable completes.

(If the source Observable does not emit any values, the AsyncSubject also completes without emitting any values.)

`

                SubjectObserverType
                `

Undocumented

Declaration

Swift

public typealias SubjectObserverType = AsyncSubject<Element>

`

                hasObservers
                `

Indicates whether the subject has any observers

Declaration

Swift

public var hasObservers: Bool { get }

`

                init()
                `

Creates a subject.

Declaration

Swift

override public init()

`

                on(_:)
                `

Notifies all subscribed observers about next event.

Declaration

Swift

public func on(_ event: Event<Element>)

Parameters

| event |

Event to send to the observers.

|

`

                subscribe(_:)
                `

Subscribes an observer to the subject.

Declaration

Swift

override public func subscribe<Observer>(_ observer: Observer) -> Disposable where Element == Observer.Element, Observer : ObserverType

Parameters

| observer |

Observer to subscribe to the subject.

|

Return Value

Disposable object that can be used to unsubscribe the observer from the subject.

`

                asObserver()
                `

Returns observer interface for subject.

Declaration

Swift

public func asObserver() -> AsyncSubject<Element>