sendStreamingRequest<T> abstract method

Stream<T> sendStreamingRequest<T>(
  1. int command,
  2. List args, {
  3. SquadronCallback onDone = Channel.noop,
  4. CancellationToken? token,
  5. bool inspectRequest = false,
  6. 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});