Correctly propagate END_OF_STREAM through Opus decoder.

extensions/opus/src/main/java/com/google/android/exoplayer/ext/opus/OpusDecoderWrapper.java

@@ -203,6 +203,7 @@ import java.util.LinkedList;
     }
     }
 
 
     // Decode.
     // Decode.
+    boolean skipBuffer = false;
     if (inputBuffer.getFlag(FLAG_END_OF_STREAM)) {
     if (inputBuffer.getFlag(FLAG_END_OF_STREAM)) {
       outputBuffer.setFlag(FLAG_END_OF_STREAM);
       outputBuffer.setFlag(FLAG_END_OF_STREAM);
     } else {
     } else {
@@ -221,13 +222,14 @@ import java.util.LinkedList;
       if (skipSamples > 0) {
       if (skipSamples > 0) {
         int bytesPerSample = opusHeader.channelCount * 2;
         int bytesPerSample = opusHeader.channelCount * 2;
         int skipBytes = skipSamples * bytesPerSample;
         int skipBytes = skipSamples * bytesPerSample;
-        if (outputBuffer.size < skipBytes) {
+        if (outputBuffer.size <= skipBytes) {
           skipSamples -= outputBuffer.size / bytesPerSample;
           skipSamples -= outputBuffer.size / bytesPerSample;
           outputBuffer.size = 0;
           outputBuffer.size = 0;
+          skipBuffer = true;
         } else {
         } else {
           skipSamples = 0;
           skipSamples = 0;
-          outputBuffer.data.position(skipBytes);
           outputBuffer.size -= skipBytes;
           outputBuffer.size -= skipBytes;
+          outputBuffer.data.position(skipBytes);
         }
         }
       }
       }
     }
     }
@@ -235,7 +237,7 @@ import java.util.LinkedList;
     synchronized (lock) {
     synchronized (lock) {
       if (flushDecodedOutputBuffer
       if (flushDecodedOutputBuffer
           || inputBuffer.sampleHolder.isDecodeOnly()
           || inputBuffer.sampleHolder.isDecodeOnly()
-          || outputBuffer.size == 0) {
+          || skipBuffer) {
         // In the following cases, we make the output buffer available again rather than queuing it
         // In the following cases, we make the output buffer available again rather than queuing it
         // to be consumed:
         // to be consumed:
         // 1) A flush occured whilst we were decoding.
         // 1) A flush occured whilst we were decoding.