AsyncSchedulerWithStreams<Request_T, Response_T, Message_T> constructor

AsyncSchedulerWithStreams<Request_T, Response_T, Message_T>({ int concurrency = 1, required AsyncTaskWithSend<Request_T, Response_T, Message_T> task, })

Implementation

AsyncSchedulerWithStreams({
  int super.concurrency = 1,
  required this.task,
});