AsyncSchedulerWithStreams<Request_T, Response_T, Message_T> constructor

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

Implementation

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