TakeOp.TakeOp

Undocumented in source.

template TakeOp(Stream)

struct TakeOp (

Receiver

) {

import concurrency.operations : withStopSource;;

import std.traits : ReturnType;;

alias SS = ReturnType!(withStopSource!(Properties.Sender));

alias Op = OpType!(SS, TakeReceiver!(Receiver, Properties.Sender.Value));

Properties.DG dg;

StopSource stopSource;

this(typeof(this) rhs);

this(Stream stream, size_t n, Properties.DG dg, Receiver receiver);

void start();

}

Constructors

this this(typeof(this) rhs): Undocumented in source.
this this(Stream stream, size_t n, Properties.DG dg, Receiver receiver): Undocumented in source.

Postblit

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

Members

Aliases

Op alias Op = OpType!(SS, TakeReceiver!(Receiver, Properties.Sender.Value)): Undocumented in source.
SS alias SS = ReturnType!(withStopSource!(Properties.Sender)): Undocumented in source.

Functions

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

Variables

dg Properties.DG dg;: Undocumented in source.
n size_t n;: Undocumented in source.
op Op op;: Undocumented in source.
stopSource StopSource stopSource;: Undocumented in source.

Meta

Source

See Implementation

concurrency stream take TakeOp aliases

Properties

structs

TakeOp