stopStream method

Future<void> stopStream(
  1. String streamName
)

Stop a stream (pause polling, keep stream in registry for potential resumption)

Implementation

Future<void> stopStream(String streamName) async {
  _pendingStarts.remove(streamName);
  await _controller.stopStream(streamName);
  // If coordinator, also handle local stream
  if (isCoordinator) {
    final DataStream? stream = await _getDataStreamLocked(streamName);
    if (stream != null && stream.started) {
      await stream.stop(); // This now just pauses polling
      logger.info('COORDINATOR Stopped stream: $streamName');
    }
  }
}