JoinPublisher

Listens to a number of publishers, and as soon as all of them emit a result at least once, emits an event.

Only emits events once; if a publisher emits multiple events, only the first one is used. Does not publish any values on finish.

@safe

class JoinPublisher : Publisher!() {

this(Publisher!()[] publishers);

void subscribe(Subscriber!() subscriber);

}

Constructors

this this(Publisher!()[] publishers): Undocumented in source.

Members

Functions

subscribe void subscribe(Subscriber!() subscriber): Undocumented in source. Be warned that the author may not have intended to support it.

Meta

Source

See Implementation

fluid future pipe aliases

classes

enums

functions

interfaces

Subscriber

structs

Event

templates