Merge branch 'fix/async_load' into minor

Author: ryanheise

just_audio/CHANGELOG.md

@@ -1,6 +1,9 @@
 ## 0.10.1
 
 * Fix unhandled PlayerInterruptedException.
+* Fix duplicate load in active state.
+* Synchronize playlist API calls.
+* Improve position accuracy over Bluetooth on Android.
 
 ## 0.10.0
 

just_audio/android/src/main/java/com/ryanheise/just_audio/AudioPlayer.java

@@ -11,6 +11,7 @@
 import androidx.media3.common.C;
 import androidx.media3.exoplayer.DefaultLivePlaybackSpeedControl;
 import androidx.media3.exoplayer.DefaultLoadControl;
+import androidx.media3.exoplayer.DefaultRenderersFactory;
 import androidx.media3.exoplayer.ExoPlaybackException;
 import androidx.media3.exoplayer.LivePlaybackSpeedControl;
 import androidx.media3.exoplayer.LoadControl;
@@ -25,6 +26,9 @@
 import androidx.media3.common.TrackSelectionParameters;
 import androidx.media3.common.TrackSelectionParameters.AudioOffloadPreferences;
 import androidx.media3.common.AudioAttributes;
+import androidx.media3.exoplayer.NoSampleRenderer;
+import androidx.media3.exoplayer.Renderer;
+import androidx.media3.exoplayer.RenderersFactory;
 import androidx.media3.extractor.DefaultExtractorsFactory;
 import androidx.media3.common.Metadata;
 import androidx.media3.exoplayer.metadata.MetadataOutput;
@@ -250,7 +254,9 @@ public void onTracksChanged(Tracks tracks) {
     }
 
     private boolean updatePositionIfChanged() {
-        if (getCurrentPosition() == updatePosition) return false;
+        if (!player.getPlayWhenReady() || processingState != ProcessingState.ready) {
+            if (getCurrentPosition() == updatePosition) return false;
+        }
         updatePosition = getCurrentPosition();
         updateTime = System.currentTimeMillis();
         return true;
@@ -749,7 +755,14 @@ private void load(final List<MediaSource> mediaSources, ShuffleOrder shuffleOrde
 
     private void ensurePlayerInitialized() {
         if (player == null) {
-            ExoPlayer.Builder builder = new ExoPlayer.Builder(context);
+            RenderersFactory renderersFactory = (eventHandler, videoListener, audioListener, textOutput, metadataOutput) -> {
+                Renderer[] defaultRenderers = new DefaultRenderersFactory(context)
+                    .createRenderers(eventHandler, videoListener, audioListener, textOutput, metadataOutput);
+                Renderer[] allRenderers = Arrays.copyOf(defaultRenderers, defaultRenderers.length + 1);
+                allRenderers[defaultRenderers.length] = new ObserverRenderer();
+                return allRenderers;
+            };
+            ExoPlayer.Builder builder = new ExoPlayer.Builder(context, renderersFactory);
             builder.setUseLazyPreparation(useLazyPreparation);
             if (loadControl != null) {
                 builder.setLoadControl(loadControl);
@@ -1103,4 +1116,31 @@ enum ProcessingState {
         ready,
         completed
     }
+
+    public class ObserverRenderer extends NoSampleRenderer {
+        private long lastPosUs = 0L;
+        private int consecutivePosCount = 0;
+
+        @Override
+        public void render(long positionUs, long elapsedRealtimeUs) {
+            if (positionUs == lastPosUs) {
+                consecutivePosCount++;
+            } else {
+                if (consecutivePosCount >= 3) {
+                    handler.post(() -> {
+                        if (updatePositionIfChanged()) {
+                            broadcastImmediatePlaybackEvent();
+                        }
+                    });
+                }
+                consecutivePosCount = 0;
+            }
+            lastPosUs = positionUs;
+        }
+
+        @Override
+        public String getName() {
+            return "ObserverRenderer";
+        }
+    }
 }