cancelStream method

Future<void> cancelStream()

Implementation

Future<void> cancelStream() async {
  await _writerQueue.close();
}