FlatMapBaseStreamOp.FlatMapBaseStreamOp

Undocumented in source.

template FlatMapBaseStreamOp(Stream, Fun, OnOverlap overlap)

struct FlatMapBaseStreamOp (

Receiver

) {

alias State = .State!(Properties.Sender.Value, InnerSender.Value, Receiver, overlap);

alias Op = OpType!(Properties.Sender, StreamReceiver!State);

alias InnerOp = OpType!(InnerSender, InnerSenderReceiver!State);

InnerOp innerOp;

this(typeof(this) rhs);

this(Stream stream, Fun fun, DG dg, Receiver receiver);

static if(is(Properties.ElementType == void))

static if(!(is(Properties.ElementType == void)))

void item(Properties.ElementType t);

void start();

}

Constructors

this this(typeof(this) rhs): Undocumented in source.
this this(Stream stream, Fun fun, DG dg, Receiver receiver): Undocumented in source.

Postblit

this(this) this(this): Undocumented in source.

Members

Aliases

InnerOp alias InnerOp = OpType!(InnerSender, InnerSenderReceiver!State): Undocumented in source.
Op alias Op = OpType!(Properties.Sender, StreamReceiver!State): Undocumented in source.
State alias State = .State!(Properties.Sender.Value, InnerSender.Value, Receiver, overlap): Undocumented in source.

Functions

item void item(): Undocumented in source. Be warned that the author may not have intended to support it.
item void item(Properties.ElementType t): Undocumented in source. Be warned that the author may not have intended to support it.
start void start(): Undocumented in source. Be warned that the author may not have intended to support it.

Variables

fun Fun fun;: Undocumented in source.
innerOp InnerOp innerOp;: Undocumented in source.
op Op op;: Undocumented in source.
state State state;: Undocumented in source.

Meta

Source

See Implementation

concurrency stream flatmapbase FlatMapBaseStreamOp aliases

structs

FlatMapBaseStreamOp