AsyncMessageGrouper constructor

AsyncMessageGrouper(
  1. Stream<List<int>> inputStream
)

Implementation

AsyncMessageGrouper(Stream<List<int>> inputStream)
    : _inputQueue = StreamQueue(inputStream);