sendStreamingRequest<T> abstract method
Stream<T>
sendStreamingRequest<T>(
- int command,
- List args, {
- SquadronCallback onDone = Channel.noop,
- CancellationToken? token,
- bool inspectRequest = false,
- bool inspectResponse = false,
Creates a WorkerRequest and sends it to the worker. This method expects a stream of values from the worker.
The worker must send a WorkerResponse.closeStream
message to close the Stream.
Implementation
Stream<T> sendStreamingRequest<T>(int command, List args,
{SquadronCallback onDone = Channel.noop,
CancellationToken? token,
bool inspectRequest = false,
bool inspectResponse = false});