Ensure event/dataEvent platform streams are broadcast streams.

ryanheise · Jul 17, 2021 · 1b71307 · 1b71307
1 parent f3371d8
commit 1b71307
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/just_audio_background/lib/just_audio_background.dart b/just_audio_background/lib/just_audio_background.dart
@@ -147,8 +147,8 @@ class _JustAudioBackgroundPlugin extends JustAudioPlatform {
 }
 
 class _JustAudioPlayer extends AudioPlayerPlatform {
-  final eventController = StreamController<PlaybackEventMessage>();
-  final playerDataController = StreamController<PlayerDataMessage>();
+  final eventController = StreamController<PlaybackEventMessage>.broadcast();
+  final playerDataController = StreamController<PlayerDataMessage>.broadcast();
   bool? _playing;
   int? _index;
   Duration? _duration;

diff --git a/just_audio_platform_interface/lib/just_audio_platform_interface.dart b/just_audio_platform_interface/lib/just_audio_platform_interface.dart
@@ -60,13 +60,13 @@ abstract class AudioPlayerPlatform {
 
   AudioPlayerPlatform(this.id);
 
-  /// A stream of playback events.
+  /// A broadcast stream of playback events.
   Stream<PlaybackEventMessage> get playbackEventMessageStream {
     throw UnimplementedError(
         'playbackEventMessageStream has not been implemented.');
   }
 
-  /// A stream of data updates.
+  /// A broadcast stream of data updates.
   Stream<PlayerDataMessage> get playerDataMessageStream =>
       Stream<PlayerDataMessage>.empty();
 

diff --git a/just_audio_web/lib/just_audio_web.dart b/just_audio_web/lib/just_audio_web.dart
@@ -39,8 +39,8 @@ class JustAudioPlugin extends JustAudioPlatform {
 
 /// The web impluementation of [AudioPlayerPlatform].
 abstract class JustAudioPlayer extends AudioPlayerPlatform {
-  final _eventController = StreamController<PlaybackEventMessage>();
-  final _dataEventController = StreamController<PlayerDataMessage>();
+  final _eventController = StreamController<PlaybackEventMessage>.broadcast();
+  final _dataEventController = StreamController<PlayerDataMessage>.broadcast();
   ProcessingStateMessage _processingState = ProcessingStateMessage.idle;
   bool _playing = false;
   int? _index;