Prevent dispose from hanging

ryanheise · Aug 8, 2020 · fc9e6e0 · fc9e6e0
1 parent 858c6c0
commit fc9e6e0
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/android/src/main/java/com/ryanheise/just_audio/AudioPlayer.java b/android/src/main/java/com/ryanheise/just_audio/AudioPlayer.java
@@ -674,6 +674,9 @@ public void dispose() {
 			player = null;
 			transition(ProcessingState.none);
 		}
+		if (eventSink != null) {
+			eventSink.endOfStream();
+		}
 		onDispose.run();
 	}
 

diff --git a/lib/just_audio.dart b/lib/just_audio.dart
@@ -567,14 +567,11 @@ class AudioPlayer {
     _proxy?.stop();
     await _durationSubject.close();
     await _eventChannelStreamSubscription.cancel();
-    await _playbackEventSubject.close();
     await _loopModeSubject.close();
     await _shuffleModeEnabledSubject.close();
     await _playingSubject.close();
     await _volumeSubject.close();
     await _speedSubject.close();
-    await _playerStateSubject.drain();
-    await _playerStateSubject.close();
     if (_positionSubject != null) {
       await _positionSubject.close();
     }