Treatment sendStream

distrib::sendStream

Generics

◻ S: Serialize

Configuration

⬡ distributor: distrib::DistributionEngine

Parameters

↳ var name: string

Inputs

⇥ data: Stream<S>
⇥ distribution_id: Block<u64>

Treatment send_stream for sending a stream of values to a distributed instance input.

Values received on data are serialized and forwarded to the remote treatment. The treatment handles automatic closing of the remote input when the stream ends or an error occurs.