Source: lib/util/operation_manager.js

  1. /*! @license
  2.  * Shaka Player
  3.  * Copyright 2016 Google LLC
  4.  * SPDX-License-Identifier: Apache-2.0
  5.  */
  7. goog.provide('shaka.util.OperationManager');
  9. goog.require('shaka.util.ArrayUtils');
  10. goog.require('shaka.util.IDestroyable');
  12. /**
  13.  * A utility for cleaning up AbortableOperations, to help simplify common
  14.  * patterns and reduce code duplication.
  15.  *
  16.  * @implements {shaka.util.IDestroyable}
  17.  */
  18. shaka.util.OperationManager = class {
  19.   /** */
  20.   constructor() {
  21.     /** @private {!Array.<!shaka.extern.IAbortableOperation>} */
  22.     this.operations_ = [];
  23.   }
  25.   /**
  26.    * Manage an operation.  This means aborting it on destroy() and removing it
  27.    * from the management set when it complete.
  28.    *
  29.    * @param {!shaka.extern.IAbortableOperation} operation
  30.    */
  31.   manage(operation) {
  32.     this.operations_.push(operation.finally(() => {
  33.       shaka.util.ArrayUtils.remove(this.operations_, operation);
  34.     }));
  35.   }
  37.   /** @override */
  38.   destroy() {
  39.     const cleanup = [];
  40.     for (const op of this.operations_) {
  41.       // Catch and ignore any failures.  This silences error logs in the
  42.       // JavaScript console about uncaught Promise failures.
  43.       op.promise.catch(() => {});
  45.       // Now abort the operation.
  46.       cleanup.push(op.abort());
  47.     }
  49.     this.operations_ = [];
  50.     return Promise.all(cleanup);
  51.   }
  52. };