stopStream method

@override Future<void> stopStream()

Stops the current stream and cleans up resources.

Implementation

@override
Future<void> stopStream() async {
  if (_controller != null && !_controller!.isClosed) {
    if (config.includeMetadata) {
      _controller!.add(StreamData.text('', metadata: {'status': 'stopped'}));
    }
    await _controller!.close();
  }
  _controller = null;
}