ReplaySubject

public class ReplaySubject<Element>:
    Observable<Element>,
    SubjectType,
    ObserverType,
    Disposable

Represents an object that is both an observable sequence as well as an observer.

Each notification is broadcasted to all subscribed and future observers, subject to buffer trimming policies.

`

                SubjectObserverType
                `

Undocumented

Declaration

Swift

public typealias SubjectObserverType = ReplaySubject<Element>

`

                hasObservers
                `

Indicates whether the subject has any observers

Declaration

Swift

public var hasObservers: Bool { get }

`

                on(_:)
                `

Notifies all subscribed observers about next event.

Declaration

Swift

public func on(_: Event<Element>)

Parameters

| event |

Event to send to the observers.

|

`

                asObserver()
                `

Returns observer interface for subject.

Declaration

Swift

public func asObserver() -> ReplaySubject<Element>

`

                dispose()
                `

Unsubscribe all observers and release resources.

Declaration

Swift

public func dispose()

`

                create(bufferSize:)
                `

Creates new instance of ReplaySubject that replays at most bufferSize last elements of sequence.

Declaration

Swift

public static func create(bufferSize: Int) -> ReplaySubject<Element>

Parameters

| bufferSize |

Maximal number of elements to replay to observer after subscription.

|

Return Value

New instance of replay subject.

`

                createUnbounded()
                `

Creates a new instance of ReplaySubject that buffers all the elements of a sequence. To avoid filling up memory, developer needs to make sure that the use case will only ever store a ‘reasonable’ number of elements.

Declaration

Swift

public static func createUnbounded() -> ReplaySubject<Element>