Simplify FrameConsumptionManager onReadyToAcceptInputFrame logic

Propagate the "end of current stream" signal directly after queueing the
last frame, instead of waiting for the next onReadyToAcceptInputFrame()
call.

PiperOrigin-RevId: 532739462
(cherry picked from commit 410debdc69150c30807e96da13ae83342817b126)

library/effect/src/main/java/com/google/android/exoplayer2/effect/FrameConsumptionManager.java

@@ -63,16 +63,16 @@ import java.util.Queue;
       return;
       return;
     }
     }
 
 
-    long presentationTimeUs = pendingFrame.second;
-    if (presentationTimeUs == C.TIME_END_OF_SOURCE) {
-      consumingGlShaderProgramInputCapacity++;
-      videoFrameProcessingTaskExecutor.submit(
-          consumingGlShaderProgram::signalEndOfCurrentInputStream);
-    } else {
     videoFrameProcessingTaskExecutor.submit(
     videoFrameProcessingTaskExecutor.submit(
         () ->
         () ->
             consumingGlShaderProgram.queueInputFrame(
             consumingGlShaderProgram.queueInputFrame(
-                  /* inputTexture= */ pendingFrame.first, presentationTimeUs));
+                /* inputTexture= */ pendingFrame.first,
+                /* presentationTimeUs= */ pendingFrame.second));
+    @Nullable Pair<GlTextureInfo, Long> nextPendingFrame = availableFrames.peek();
+    if (nextPendingFrame != null && nextPendingFrame.second == C.TIME_END_OF_SOURCE) {
+      videoFrameProcessingTaskExecutor.submit(
+          consumingGlShaderProgram::signalEndOfCurrentInputStream);
+      availableFrames.remove();
     }
     }
   }
   }