Merge pull request #1312 from canalplus/misc/remove-next-tick-dependency

v4: Remove next-tick dependency

demo/full/scripts/globals.d.ts

@@ -1,3 +1,2 @@
 import "../../../src/typings/globals.d";
-import "../../../src/typings/next-tick";
 import "../../../src/typings/object-assign";

package.json

@@ -167,9 +167,6 @@
     "type": "git",
     "url": "git://github.com/canalplus/rx-player.git"
   },
-  "dependencies": {
-    "next-tick": "1.1.0"
-  },
   "devDependencies": {
     "@babel/core": "7.23.0",
     "@babel/plugin-transform-runtime": "7.22.15",

src/compat/patch_webkit_source_buffer.ts

@@ -14,8 +14,8 @@
  * limitations under the License.
  */
 
-import nextTick from "next-tick";
 import EventEmitter from "../utils/event_emitter";
+import queueMicrotask from "../utils/queue_microtask";
 import globalScope from "./global_scope";
 import isNode from "./is_node";
 
@@ -57,7 +57,7 @@ export default function patchWebkitSourceBuffer() : void {
 
     sourceBufferWebkitProto._emitUpdate =
       function(eventName : string, val : unknown) {
-        nextTick(() => {
+        queueMicrotask(() => {
           /* eslint-disable no-invalid-this */
           this.trigger(eventName, val);
           this.updating = false;

src/core/stream/adaptation/adaptation_stream.ts

@@ -1,4 +1,3 @@
-import nextTick from "next-tick";
 import config from "../../../config";
 import { formatError } from "../../../errors";
 import log from "../../../log";
@@ -7,6 +6,7 @@ import assertUnreachable from "../../../utils/assert_unreachable";
 import cancellableSleep from "../../../utils/cancellable_sleep";
 import noop from "../../../utils/noop";
 import objectAssign from "../../../utils/object_assign";
+import queueMicrotask from "../../../utils/queue_microtask";
 import SharedReference, {
   createMappedReference,
   IReadOnlySharedReference,
@@ -192,7 +192,7 @@ export default function AdaptationStream(
         // conditions where the inner logic would be called synchronously before
         // the next observation (which may reflect very different playback conditions)
         // is actually received.
-        return nextTick(() => {
+        return queueMicrotask(() => {
           playbackObserver.listen(() => {
             if (fnCancelSignal.isCancelled()) {
               return;

src/core/stream/orchestrator/stream_orchestrator.ts

@@ -14,14 +14,14 @@
  * limitations under the License.
  */
 
-import nextTick from "next-tick";
 import config from "../../../config";
 import { MediaError } from "../../../errors";
 import log from "../../../log";
 import Manifest, {
   IDecipherabilityUpdateElement,
   Period,
 } from "../../../manifest";
+import queueMicrotask from "../../../utils/queue_microtask";
 import {
   createMappedReference,
   IReadOnlySharedReference,
@@ -351,7 +351,7 @@ export default function StreamOrchestrator(
       // Schedule micro task before checking the last playback observation
       // to reduce the risk of race conditions where the next observation
       // was going to be emitted synchronously.
-      nextTick(() => {
+      queueMicrotask(() => {
         if (orchestratorCancelSignal.isCancelled()) {
           return ;
         }
@@ -554,7 +554,7 @@ export default function StreamOrchestrator(
               // conditions where the inner logic would be called synchronously before
               // the next observation (which may reflect very different playback
               // conditions) is actually received.
-              return nextTick(() => {
+              return queueMicrotask(() => {
                 if (innerCancelSignal.isCancelled()) {
                   return;
                 }

src/core/stream/period/period_stream.ts

@@ -14,7 +14,6 @@
  * limitations under the License.
  */
 
-import nextTick from "next-tick";
 import config from "../../../config";
 import {
   formatError,
@@ -26,6 +25,7 @@ import {
   Period,
 } from "../../../manifest";
 import objectAssign from "../../../utils/object_assign";
+import queueMicrotask from "../../../utils/queue_microtask";
 import { getLeftSizeOfBufferedTimeRange } from "../../../utils/ranges";
 import SharedReference, {
   IReadOnlySharedReference,
@@ -362,7 +362,7 @@ export default function PeriodStream(
     // is actually received.
     // It can happen when `askForMediaSourceReload` is called as a side-effect of
     // the same event that triggers the playback observation to be emitted.
-    nextTick(() => {
+    queueMicrotask(() => {
       playbackObserver.listen(() => {
         if (cancelSignal.isCancelled()) {
           return;

src/utils/queue_microtask.ts

@@ -0,0 +1,7 @@
+export default typeof queueMicrotask === "function" ?
+  queueMicrotask :
+  function queueMicrotaskPonyfill(
+    cb: () => void
+  ): void {
+    Promise.resolve().then(cb, () => cb());
+  };