fluid ~master (2025-03-22T14:27:06.5478146)

Publisher

fluid future pipe

A publisher sends emits events that other objects can listen to.

  1. alias Publisher(Output : void) = Publisher!()
  2. interface Publisher(Outputs...)
    @safe
    interface Publisher (
    Outputs...
    ) if (
    !is(Output == void)
    ) {
    alias Output = Outputs[0];
    alias Output = Outputs;
    void subscribe(Subscriber!Output subscriber);
    auto then(T delegate(Output) @(safe) next);
    }

Members

Aliases

Output
alias Output = Outputs[0]
Undocumented in source.
Output
alias Output = Outputs
Undocumented in source.

Functions

subscribe
void subscribe(Subscriber!Output subscriber)

Low-level API to directly subscribe to the data sent by this publisher.

then
auto then(T delegate(Output) @(safe) next)

Connect a listener to the publisher.

Meta

Source

See Implementation

fluid future pipe aliasesclassesenumsfunctionsinterfacesstructstemplates

Page generated by adrdox