Treatment recvStream

distrib::recvStream

Generics

◻ D: Deserialize

Configuration

⬡ distributor: distrib::DistributionEngine

Parameters

↳ var name: string

Inputs

⇥ distribution_id: Block<u64>

Outputs

↦ data: Stream<D>

Treatment recv_stream for receiving streaming output from a distributed instance.

• name is the name of the output port defined by the distributed treatment.
• distribution_id provides the identifier obtained from distribute.

The treatment forwards each value received from the remote output into the data stream, converting raw values back into the requested generic type D. If a value of the wrong datatype is encountered the stream is closed.