reset method

@override Future<void> reset()

Closes both ends of the stream

Implementation

@override
Future<void> reset() async {
  if (_isClosed) return;
  try {
    await _underlyingMuxedStream.reset();
  } catch (e) {
    // Log error, but proceed with local cleanup
    print('Error resetting underlying muxed stream: $e');
  } finally {
    await _handleResetOrClose();
  }
}