Closes the stream.
stream
Future<Unit> dispose() async { await _streamController?.close(); return const Unit(); }