Merge branch 'main' into segment-sequence-representation

lib/dash/dash_parser.js

@@ -217,8 +217,10 @@ shaka.dash.DashParser = class {
    * @exportInterface
    */
   onInitialVariantChosen(variant) {
-    if (this.manifest_ && this.lowLatencyMode_ &&
-        this.minTotalAvailabilityTimeOffset_) {
+    // For live it is necessary that the first time we update the manifest with
+    // a shorter time than indicated to take into account that the last segment
+    // added could be halfway, for example
+    if (this.manifest_ && this.manifest_.presentationTimeline.isLive()) {
       const stream = variant.video || variant.audio;
       if (stream && stream.segmentIndex) {
         const availabilityEnd =

lib/media/segment_prefetch.js

@@ -4,12 +4,15 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
+goog.provide('shaka.media.SegmentPrefetch');
+
 goog.require('goog.asserts');
-goog.require('shaka.net.NetworkingEngine');
+goog.require('shaka.log');
 goog.require('shaka.media.InitSegmentReference');
 goog.require('shaka.media.SegmentReference');
-goog.provide('shaka.media.SegmentPrefetch');
-goog.require('shaka.log');
+goog.require('shaka.net.NetworkingEngine');
+goog.require('shaka.util.Uint8ArrayUtils');
+
 
 /**
  * @summary
@@ -227,10 +230,19 @@ shaka.media.SegmentPrefetchOperation = class {
    * @public
    */
   dispatchFetch(reference, stream) {
+    // We need to store the data, because streamDataCallback_ might not be
+    // available when you start getting the first data.
+    let buffered = new Uint8Array(0);
     this.operation_ = this.fetchDispatcher_(
         reference, stream, async (data) => {
+          if (buffered.byteLength > 0) {
+            buffered = shaka.util.Uint8ArrayUtils.concat(buffered, data);
+          } else {
+            buffered = data;
+          }
           if (this.streamDataCallback_) {
-            await this.streamDataCallback_(data);
+            await this.streamDataCallback_(buffered);
+            buffered = new Uint8Array(0);
           }
         });
   }