Input

Round robin input channel. Implements InputRange.

struct Input (

Message

) {

alias Complement = Output;

mixin Channel!Message ;

ptrdiff_t pending();

bool empty();

Message front();

void popFront();

Message next();

int opApply(int delegate(Message) proceed);

Message[] opSlice();

}

Destructor

~this ~this(): Fix all cursors on destroy.

Members

Aliases

Complement alias Complement = Output: Undocumented in source.

Functions

empty bool empty(): True when no more messages will be consumed.
front Message front(): Get message fromm current non clear Queue or wait. pending must be checked before.
next Message next(): Consumes current message;
opApply int opApply(int delegate(Message) proceed): Iterates over all messages.
opSlice Message[] opSlice(): Collects all messages to array.
pending ptrdiff_t pending(): Minimum count of pending messages. Negative value - new messages will never provided.
popFront void popFront(): Consume current pending message and switch to another Queue. pending must be checked before.

Mixins

__anonymous mixin Channel!Message: Undocumented in source.

Meta

Source

See Implementation

jin go input structs

Input