PendingSubject

Rocket.PendingSubject — Function

PendingSubject(::Type{D}) where D
PendingSubject(::Type{D}, factory::F) where { D, F <: AbstractFactory }
PendingSubject(::Type{D}, subject::S) where { D, S }

A variant of Subject that emits its last value on completion. Reemits last value on further subscriptions and then completes.

source

Rocket.PendingSubjectFactory — Function

PendingSubjectFactory(factory::F) where { F <: AbstractSubjectFactory }
PendingSubjectFactory(; scheduler::H = AsapScheduler()) where { H <: AbstractScheduler }

A variant of SubjectFactory that creates an instance of PendingSubject.

source

Description

A variant of Subject that only emits a value when it completes. It will emit its latest value to all its observers on completion. It will reemit its latest value to all new observers on further subscription and then complete. It is not possible to overwrite last value after completion.

Examples

using Rocket

subject = PendingSubject(Int)

subscription1 = subscribe!(subject, logger("1"))

next!(subject, 1) # Nothing is logged
next!(subject, 2) # Nothing is logged

subscription2 = subscribe!(subject, logger("2"))

next!(subject, 3) # Nothing is logged

complete!(subject)

subscription3 = subscribe!(subject, logger("3"))

[1] Data: 3
[2] Data: 3
[1] Completed
[2] Completed
[3] Data: 3
[3] Completed