Accessor

Helper for when a node needs to take multiple streams. Without this events from different streams are indistinguishable.

class Accessor : StreamListener!T(

T

) {

bool eventsComming;

Stream!T source;

AccessorOwner owner;

this(Stream!T source, AccessorOwner owner);

void onEventsComming();

void push(T[] e);

T[] takeEvents();

}

Constructors

this this(Stream!T source, AccessorOwner owner): Undocumented in source.

Destructor

~this ~this(): Undocumented in source.

Members

Functions

onEventsComming void onEventsComming(): Undocumented in source. Be warned that the author may not have intended to support it.
push void push(T[] e): Undocumented in source. Be warned that the author may not have intended to support it.
takeEvents T[] takeEvents(): Undocumented in source. Be warned that the author may not have intended to support it.

Variables

events T[] events;: Undocumented in source.
eventsComming bool eventsComming;: Undocumented in source.
owner AccessorOwner owner;: Undocumented in source.
source Stream!T source;: Undocumented in source.

Meta

Source

See Implementation

frpd stream _accessor classes

Accessor

interfaces

AccessorOwner