fix(LL-DASH): Append segment chunk strictly in order (#3405)

An async process handles the appending of partial segments for LL-DASH.  This fixes the caller to wait on the results, so that partial segments are always appended in order.

Fixes #3404

Author: percytse

externs/shaka/net.js

@@ -60,7 +60,7 @@ shaka.extern.RetryParameters;
  *   retryParameters: !shaka.extern.RetryParameters,
  *   licenseRequestType: ?string,
  *   sessionId: ?string,
- *   streamDataCallback: ?function(BufferSource)
+ *   streamDataCallback: ?function(BufferSource):!Promise
  * }}
  *
  * @description
@@ -90,7 +90,7 @@ shaka.extern.RetryParameters;
  * @property {?string} sessionId
  *   If this is a LICENSE request, this field contains the session ID of the
  *   EME session that made the request.
- * @property {?function(BufferSource)} streamDataCallback
+ * @property {?function(BufferSource):!Promise} streamDataCallback
  *   A callback function to handle the chunked data of the ReadableStream.
  * @exportDoc
  */

lib/media/streaming_engine.js

@@ -1738,7 +1738,7 @@ shaka.media.StreamingEngine = class {
    * @param {!shaka.media.StreamingEngine.MediaState_} mediaState
    * @param {(!shaka.media.InitSegmentReference|!shaka.media.SegmentReference)}
    *   reference
-   * @param {?function(BufferSource)=} streamDataCallback
+   * @param {?function(BufferSource):!Promise=} streamDataCallback
    *
    * @return {!Promise.<BufferSource>}
    * @private

lib/net/http_fetch_plugin.js

@@ -92,7 +92,7 @@ shaka.net.HttpFetchPlugin = class {
    * @param {!RequestInit} init
    * @param {shaka.net.HttpFetchPlugin.AbortStatus} abortStatus
    * @param {shaka.extern.ProgressUpdated} progressUpdated
-   * @param {?function(BufferSource)} streamDataCallback
+   * @param {?function(BufferSource):!Promise} streamDataCallback
    * @return {!Promise<!shaka.extern.Response>}
    * @private
    */
@@ -140,7 +140,7 @@ shaka.net.HttpFetchPlugin = class {
           if (!readObj.done) {
             loaded += readObj.value.byteLength;
             if (streamDataCallback) {
-              streamDataCallback(readObj.value);
+              await streamDataCallback(readObj.value);
             }
           }
 

lib/net/networking_engine.js

@@ -196,7 +196,7 @@ shaka.net.NetworkingEngine = class extends shaka.util.FakeEventTarget {
    *
    * @param {!Array.<string>} uris
    * @param {shaka.extern.RetryParameters} retryParams
-   * @param {?function(BufferSource)=} streamDataCallback
+   * @param {?function(BufferSource):!Promise=} streamDataCallback
    * @return {shaka.extern.Request}
    * @export
    */

lib/util/networking.js

@@ -26,7 +26,7 @@ shaka.util.Networking = class {
    * @param {?number} start
    * @param {?number} end
    * @param {shaka.extern.RetryParameters} retryParameters
-   * @param {?function(BufferSource)=} streamDataCallback
+   * @param {?function(BufferSource):!Promise=} streamDataCallback
    * @return {shaka.extern.Request}
    */
   static createSegmentRequest(uris, start, end, retryParameters,