https://www.rai.it/common/assets/js/webcomponents/railytics.js

1var Be = Object.defineProperty;
2var Me = (t, n, e) => n in t ? Be(t, n, { enumerable: !0, configurable: !0, writable: !0, value: e }) : t[n] = e;
3var D = (t, n, e) => (Me(t, typeof n != "symbol" ? n + "" : n, e), e);
4var W = function(t, n) {
5  return W = Object.setPrototypeOf || { __proto__: [] } instanceof Array && function(e, r) {
6    e.__proto__ = r;
7  } || function(e, r) {
8    for (var i in r)
9      Object.prototype.hasOwnProperty.call(r, i) && (e[i] = r[i]);
10  }, W(t, n);
11};
12function k(t, n) {
13  if (typeof n != "function" && n !== null)
14    throw new TypeError("Class extends value " + String(n) + " is not a constructor or null");
15  W(t, n);
16  function e() {
17    this.constructor = t;
18  }
19  t.prototype = n === null ? Object.create(n) : (e.prototype = n.prototype, new e());
20}
21function Ue(t, n, e, r) {
22  function i(o) {
23    return o instanceof e ? o : new e(function(s) {
24      s(o);
25    });
26  }
27  return new (e || (e = Promise))(function(o, s) {
28    function u(d) {
29      try {
30        a(r.next(d));
31      } catch (v) {
32        s(v);
33      }
34    }
35    function c(d) {
36      try {
37        a(r.throw(d));
38      } catch (v) {
39        s(v);
40      }
41    }
42    function a(d) {
43      d.done ? o(d.value) : i(d.value).then(u, c);
44    }
45    a((r = r.apply(t, n || [])).next());
46  });
47}
48function we(t, n) {
49  var e = { label: 0, sent: function() {
50    if (o[0] & 1)
51      throw o[1];
52    return o[1];
53  }, trys: [], ops: [] }, r, i, o, s;
54  return s = { next: u(0), throw: u(1), return: u(2) }, typeof Symbol == "function" && (s[Symbol.iterator] = function() {
55    return this;
56  }), s;
57  function u(a) {
58    return function(d) {
59      return c([a, d]);
60    };
61  }
62  function c(a) {
63    if (r)
64      throw new TypeError("Generator is already executing.");
65    for (; s && (s = 0, a[0] && (e = 0)), e; )
66      try {
67        if (r = 1, i && (o = a[0] & 2 ? i.return : a[0] ? i.throw || ((o = i.return) && o.call(i), 0) : i.next) && !(o = o.call(i, a[1])).done)
68          return o;
69        switch (i = 0, o && (a = [a[0] & 2, o.value]), a[0]) {
70          case 0:
71          case 1:
72            o = a;
73            break;
74          case 4:
75            return e.label++, { value: a[1], done: !1 };
76          case 5:
77            e.label++, i = a[1], a = [0];
78            continue;
79          case 7:
80            a = e.ops.pop(), e.trys.pop();
81            continue;
82          default:
83            if (o = e.trys, !(o = o.length > 0 && o[o.length - 1]) && (a[0] === 6 || a[0] === 2)) {
84              e = 0;
85              continue;
86            }
87            if (a[0] === 3 && (!o || a[1] > o[0] && a[1] < o[3])) {
88              e.label = a[1];
89              break;
90            }
91            if (a[0] === 6 && e.label < o[1]) {
92              e.label = o[1], o = a;
93              break;
94            }
95            if (o && e.label < o[2]) {
96              e.label = o[2], e.ops.push(a);
97              break;
98            }
99            o[2] && e.ops.pop(), e.trys.pop();
100            continue;
101        }
102        a = n.call(t, e);
103      } catch (d) {
104        a = [6, d], i = 0;
105      } finally {
106        r = o = 0;
107      }
108    if (a[0] & 5)
109      throw a[1];
110    return { value: a[0] ? a[1] : void 0, done: !0 };
111  }
112}
113function _(t) {
114  var n = typeof Symbol == "function" && Symbol.iterator, e = n && t[n], r = 0;
115  if (e)
116    return e.call(t);
117  if (t && typeof t.length == "number")
118    return {
119      next: function() {
120        return t && r >= t.length && (t = void 0), { value: t && t[r++], done: !t };
121      }
122    };
123  throw new TypeError(n ? "Object is not iterable." : "Symbol.iterator is not defined.");
124}
125function G(t, n) {
126  var e = typeof Symbol == "function" && t[Symbol.iterator];
127  if (!e)
128    return t;
129  var r = e.call(t), i, o = [], s;
130  try {
131    for (; (n === void 0 || n-- > 0) && !(i = r.next()).done; )
132      o.push(i.value);
133  } catch (u) {
134    s = { error: u };
135  } finally {
136    try {
137      i && !i.done && (e = r.return) && e.call(r);
138    } finally {
139      if (s)
140        throw s.error;
141    }
142  }
143  return o;
144}
145function K(t, n, e) {
146  if (e || arguments.length === 2)
147    for (var r = 0, i = n.length, o; r < i; r++)
148      (o || !(r in n)) && (o || (o = Array.prototype.slice.call(n, 0, r)), o[r] = n[r]);
149  return t.concat(o || Array.prototype.slice.call(n));
150}
151function P(t) {
152  return this instanceof P ? (this.v = t, this) : new P(t);
153}
154function $e(t, n, e) {
155  if (!Symbol.asyncIterator)
156    throw new TypeError("Symbol.asyncIterator is not defined.");
157  var r = e.apply(t, n || []), i, o = [];
158  return i = {}, u("next"), u("throw"), u("return", s), i[Symbol.asyncIterator] = function() {
159    return this;
160  }, i;
161  function s(f) {
162    return function(h) {
163      return Promise.resolve(h).then(f, v);
164    };
165  }
166  function u(f, h) {
167    r[f] && (i[f] = function(l) {
168      return new Promise(function(m, p) {
169        o.push([f, l, m, p]) > 1 || c(f, l);
170      });
171    }, h && (i[f] = h(i[f])));
172  }
173  function c(f, h) {
174    try {
175      a(r[f](h));
176    } catch (l) {
177      b(o[0][3], l);
178    }
179  }
180  function a(f) {
181    f.value instanceof P ? Promise.resolve(f.value.v).then(d, v) : b(o[0][2], f);
182  }
183  function d(f) {
184    c("next", f);
185  }
186  function v(f) {
187    c("throw", f);
188  }
189  function b(f, h) {
190    f(h), o.shift(), o.length && c(o[0][0], o[0][1]);
191  }
192}
193function Fe(t) {
194  if (!Symbol.asyncIterator)
195    throw new TypeError("Symbol.asyncIterator is not defined.");
196  var n = t[Symbol.asyncIterator], e;
197  return n ? n.call(t) : (t = typeof _ == "function" ? _(t) : t[Symbol.iterator](), e = {}, r("next"), r("throw"), r("return"), e[Symbol.asyncIterator] = function() {
198    return this;
199  }, e);
200  function r(o) {
201    e[o] = t[o] && function(s) {
202      return new Promise(function(u, c) {
203        s = t[o](s), i(u, c, s.done, s.value);
204      });
205    };
206  }
207  function i(o, s, u, c) {
208    Promise.resolve(c).then(function(a) {
209      o({ value: a, done: u });
210    }, s);
211  }
212}
213function y(t) {
214  return typeof t == "function";
215}
216function te(t) {
217  var n = function(r) {
218    Error.call(r), r.stack = new Error().stack;
219  }, e = t(n);
220  return e.prototype = Object.create(Error.prototype), e.prototype.constructor = e, e;
221}
222var U = te(function(t) {
223  return function(e) {
224    t(this), this.message = e ? e.length + ` errors occurred during unsubscription:
225` + e.map(function(r, i) {
226      return i + 1 + ") " + r.toString();
227    }).join(`
228  `) : "", this.name = "UnsubscriptionError", this.errors = e;
229  };
230});
231function Y(t, n) {
232  if (t) {
233    var e = t.indexOf(n);
234    0 <= e && t.splice(e, 1);
235  }
236}
237var j = function() {
238  function t(n) {
239    this.initialTeardown = n, this.closed = !1, this._parentage = null, this._finalizers = null;
240  }
241  return t.prototype.unsubscribe = function() {
242    var n, e, r, i, o;
243    if (!this.closed) {
244      this.closed = !0;
245      var s = this._parentage;
246      if (s)
247        if (this._parentage = null, Array.isArray(s))
248          try {
249            for (var u = _(s), c = u.next(); !c.done; c = u.next()) {
250              var a = c.value;
251              a.remove(this);
252            }
253          } catch (l) {
254            n = { error: l };
255          } finally {
256            try {
257              c && !c.done && (e = u.return) && e.call(u);
258            } finally {
259              if (n)
260                throw n.error;
261            }
262          }
263        else
264          s.remove(this);
265      var d = this.initialTeardown;
266      if (y(d))
267        try {
268          d();
269        } catch (l) {
270          o = l instanceof U ? l.errors : [l];
271        }
272      var v = this._finalizers;
273      if (v) {
274        this._finalizers = null;
275        try {
276          for (var b = _(v), f = b.next(); !f.done; f = b.next()) {
277            var h = f.value;
278            try {
279              se(h);
280            } catch (l) {
281              o = o ?? [], l instanceof U ? o = K(K([], G(o)), G(l.errors)) : o.push(l);
282            }
283          }
284        } catch (l) {
285          r = { error: l };
286        } finally {
287          try {
288            f && !f.done && (i = b.return) && i.call(b);
289          } finally {
290            if (r)
291              throw r.error;
292          }
293        }
294      }
295      if (o)
296        throw new U(o);
297    }
298  }, t.prototype.add = function(n) {
299    var e;
300    if (n && n !== this)
301      if (this.closed)
302        se(n);
303      else {
304        if (n instanceof t) {
305          if (n.closed || n._hasParent(this))
306            return;
307          n._addParent(this);
308        }
309        (this._finalizers = (e = this._finalizers) !== null && e !== void 0 ? e : []).push(n);
310      }
311  }, t.prototype._hasParent = function(n) {
312    var e = this._parentage;
313    return e === n || Array.isArray(e) && e.includes(n);
314  }, t.prototype._addParent = function(n) {
315    var e = this._parentage;
316    this._parentage = Array.isArray(e) ? (e.push(n), e) : e ? [e, n] : n;
317  }, t.prototype._removeParent = function(n) {
318    var e = this._parentage;
319    e === n ? this._parentage = null : Array.isArray(e) && Y(e, n);
320  }, t.prototype.remove = function(n) {
321    var e = this._finalizers;
322    e && Y(e, n), n instanceof t && n._removeParent(this);
323  }, t.EMPTY = function() {
324    var n = new t();
325    return n.closed = !0, n;
326  }(), t;
327}(), ge = j.EMPTY;
328function Se(t) {
329  return t instanceof j || t && "closed" in t && y(t.remove) && y(t.add) && y(t.unsubscribe);
330}
331function se(t) {
332  y(t) ? t() : t.unsubscribe();
333}
334var Ie = {
335  onUnhandledError: null,
336  onStoppedNotification: null,
337  Promise: void 0,
338  useDeprecatedSynchronousErrorHandling: !1,
339  useDeprecatedNextContext: !1
340}, Ee = {
341  setTimeout: function(t, n) {
342    for (var e = [], r = 2; r < arguments.length; r++)
343      e[r - 2] = arguments[r];
344    return setTimeout.apply(void 0, K([t, n], G(e)));
345  },
346  clearTimeout: function(t) {
347    var n = Ee.delegate;
348    return ((n == null ? void 0 : n.clearTimeout) || clearTimeout)(t);
349  },
350  delegate: void 0
351};
352function xe(t) {
353  Ee.setTimeout(function() {
354    throw t;
355  });
356}
357function ce() {
358}
359function A(t) {
360  t();
361}
362var ne = function(t) {
363  k(n, t);
364  function n(e) {
365    var r = t.call(this) || this;
366    return r.isStopped = !1, e ? (r.destination = e, Se(e) && e.add(r)) : r.destination = Ve, r;
367  }
368  return n.create = function(e, r, i) {
369    return new H(e, r, i);
370  }, n.prototype.next = function(e) {
371    this.isStopped || this._next(e);
372  }, n.prototype.error = function(e) {
373    this.isStopped || (this.isStopped = !0, this._error(e));
374  }, n.prototype.complete = function() {
375    this.isStopped || (this.isStopped = !0, this._complete());
376  }, n.prototype.unsubscribe = function() {
377    this.closed || (this.isStopped = !0, t.prototype.unsubscribe.call(this), this.destination = null);
378  }, n.prototype._next = function(e) {
379    this.destination.next(e);
380  }, n.prototype._error = function(e) {
381    try {
382      this.destination.error(e);
383    } finally {
384      this.unsubscribe();
385    }
386  }, n.prototype._complete = function() {
387    try {
388      this.destination.complete();
389    } finally {
390      this.unsubscribe();
391    }
392  }, n;
393}(j), Le = Function.prototype.bind;
394function $(t, n) {
395  return Le.call(t, n);
396}
397var ze = function() {
398  function t(n) {
399    this.partialObserver = n;
400  }
401  return t.prototype.next = function(n) {
402    var e = this.partialObserver;
403    if (e.next)
404      try {
405        e.next(n);
406      } catch (r) {
407        C(r);
408      }
409  }, t.prototype.error = function(n) {
410    var e = this.partialObserver;
411    if (e.error)
412      try {
413        e.error(n);
414      } catch (r) {
415        C(r);
416      }
417    else
418      C(n);
419  }, t.prototype.complete = function() {
420    var n = this.partialObserver;
421    if (n.complete)
422      try {
423        n.complete();
424      } catch (e) {
425        C(e);
426      }
427  }, t;
428}(), H = function(t) {
429  k(n, t);
430  function n(e, r, i) {
431    var o = t.call(this) || this, s;
432    if (y(e) || !e)
433      s = {
434        next: e ?? void 0,
435        error: r ?? void 0,
436        complete: i ?? void 0
437      };
438    else {
439      var u;
440      o && Ie.useDeprecatedNextContext ? (u = Object.create(e), u.unsubscribe = function() {
441        return o.unsubscribe();
442      }, s = {
443        next: e.next && $(e.next, u),
444        error: e.error && $(e.error, u),
445        complete: e.complete && $(e.complete, u)
446      }) : s = e;
447    }
448    return o.destination = new ze(s), o;
449  }
450  return n;
451}(ne);
452function C(t) {
453  xe(t);
454}
455function qe(t) {
456  throw t;
457}
458var Ve = {
459  closed: !0,
460  next: ce,
461  error: qe,
462  complete: ce
463}, re = function() {
464  return typeof Symbol == "function" && Symbol.observable || "@@observable";
465}();
466function Pe(t) {
467  return t;
468}
469function We(t) {
470  return t.length === 0 ? Pe : t.length === 1 ? t[0] : function(e) {
471    return t.reduce(function(r, i) {
472      return i(r);
473    }, e);
474  };
475}
476var w = function() {
477  function t(n) {
478    n && (this._subscribe = n);
479  }
480  return t.prototype.lift = function(n) {
481    var e = new t();
482    return e.source = this, e.operator = n, e;
483  }, t.prototype.subscribe = function(n, e, r) {
484    var i = this, o = Ke(n) ? n : new H(n, e, r);
485    return A(function() {
486      var s = i, u = s.operator, c = s.source;
487      o.add(u ? u.call(o, c) : c ? i._subscribe(o) : i._trySubscribe(o));
488    }), o;
489  }, t.prototype._trySubscribe = function(n) {
490    try {
491      return this._subscribe(n);
492    } catch (e) {
493      n.error(e);
494    }
495  }, t.prototype.forEach = function(n, e) {
496    var r = this;
497    return e = ae(e), new e(function(i, o) {
498      var s = new H({
499        next: function(u) {
500          try {
501            n(u);
502          } catch (c) {
503            o(c), s.unsubscribe();
504          }
505        },
506        error: o,
507        complete: i
508      });
509      r.subscribe(s);
510    });
511  }, t.prototype._subscribe = function(n) {
512    var e;
513    return (e = this.source) === null || e === void 0 ? void 0 : e.subscribe(n);
514  }, t.prototype[re] = function() {
515    return this;
516  }, t.prototype.pipe = function() {
517    for (var n = [], e = 0; e < arguments.length; e++)
518      n[e] = arguments[e];
519    return We(n)(this);
520  }, t.prototype.toPromise = function(n) {
521    var e = this;
522    return n = ae(n), new n(function(r, i) {
523      var o;
524      e.subscribe(function(s) {
525        return o = s;
526      }, function(s) {
527        return i(s);
528      }, function() {
529        return r(o);
530      });
531    });
532  }, t.create = function(n) {
533    return new t(n);
534  }, t;
535}();
536function ae(t) {
537  var n;
538  return (n = t ?? Ie.Promise) !== null && n !== void 0 ? n : Promise;
539}
540function Ge(t) {
541  return t && y(t.next) && y(t.error) && y(t.complete);
542}
543function Ke(t) {
544  return t && t instanceof ne || Ge(t) && Se(t);
545}
546function Ye(t) {
547  return y(t == null ? void 0 : t.lift);
548}
549function T(t) {
550  return function(n) {
551    if (Ye(n))
552      return n.lift(function(e) {
553        try {
554          return t(e, this);
555        } catch (r) {
556          this.error(r);
557        }
558      });
559    throw new TypeError("Unable to lift unknown Observable type");
560  };
561}
562function x(t, n, e, r, i) {
563  return new He(t, n, e, r, i);
564}
565var He = function(t) {
566  k(n, t);
567  function n(e, r, i, o, s, u) {
568    var c = t.call(this, e) || this;
569    return c.onFinalize = s, c.shouldUnsubscribe = u, c._next = r ? function(a) {
570      try {
571        r(a);
572      } catch (d) {
573        e.error(d);
574      }
575    } : t.prototype._next, c._error = o ? function(a) {
576      try {
577        o(a);
578      } catch (d) {
579        e.error(d);
580      } finally {
581        this.unsubscribe();
582      }
583    } : t.prototype._error, c._complete = i ? function() {
584      try {
585        i();
586      } catch (a) {
587        e.error(a);
588      } finally {
589        this.unsubscribe();
590      }
591    } : t.prototype._complete, c;
592  }
593  return n.prototype.unsubscribe = function() {
594    var e;
595    if (!this.shouldUnsubscribe || this.shouldUnsubscribe()) {
596      var r = this.closed;
597      t.prototype.unsubscribe.call(this), !r && ((e = this.onFinalize) === null || e === void 0 || e.call(this));
598    }
599  }, n;
600}(ne), Qe = te(function(t) {
601  return function() {
602    t(this), this.name = "ObjectUnsubscribedError", this.message = "object unsubscribed";
603  };
604}), ie = function(t) {
605  k(n, t);
606  function n() {
607    var e = t.call(this) || this;
608    return e.closed = !1, e.currentObservers = null, e.observers = [], e.isStopped = !1, e.hasError = !1, e.thrownError = null, e;
609  }
610  return n.prototype.lift = function(e) {
611    var r = new ue(this, this);
612    return r.operator = e, r;
613  }, n.prototype._throwIfClosed = function() {
614    if (this.closed)
615      throw new Qe();
616  }, n.prototype.next = function(e) {
617    var r = this;
618    A(function() {
619      var i, o;
620      if (r._throwIfClosed(), !r.isStopped) {
621        r.currentObservers || (r.currentObservers = Array.from(r.observers));
622        try {
623          for (var s = _(r.currentObservers), u = s.next(); !u.done; u = s.next()) {
624            var c = u.value;
625            c.next(e);
626          }
627        } catch (a) {
628          i = { error: a };
629        } finally {
630          try {
631            u && !u.done && (o = s.return) && o.call(s);
632          } finally {
633            if (i)
634              throw i.error;
635          }
636        }
637      }
638    });
639  }, n.prototype.error = function(e) {
640    var r = this;
641    A(function() {
642      if (r._throwIfClosed(), !r.isStopped) {
643        r.hasError = r.isStopped = !0, r.thrownError = e;
644        for (var i = r.observers; i.length; )
645          i.shift().error(e);
646      }
647    });
648  }, n.prototype.complete = function() {
649    var e = this;
650    A(function() {
651      if (e._throwIfClosed(), !e.isStopped) {
652        e.isStopped = !0;
653        for (var r = e.observers; r.length; )
654          r.shift().complete();
655      }
656    });
657  }, n.prototype.unsubscribe = function() {
658    this.isStopped = this.closed = !0, this.observers = this.currentObservers = null;
659  }, Object.defineProperty(n.prototype, "observed", {
660    get: function() {
661      var e;
662      return ((e = this.observers) === null || e === void 0 ? void 0 : e.length) > 0;
663    },
664    enumerable: !1,
665    configurable: !0
666  }), n.prototype._trySubscribe = function(e) {
667    return this._throwIfClosed(), t.prototype._trySubscribe.call(this, e);
668  }, n.prototype._subscribe = function(e) {
669    return this._throwIfClosed(), this._checkFinalizedStatuses(e), this._innerSubscribe(e);
670  }, n.prototype._innerSubscribe = function(e) {
671    var r = this, i = this, o = i.hasError, s = i.isStopped, u = i.observers;
672    return o || s ? ge : (this.currentObservers = null, u.push(e), new j(function() {
673      r.currentObservers = null, Y(u, e);
674    }));
675  }, n.prototype._checkFinalizedStatuses = function(e) {
676    var r = this, i = r.hasError, o = r.thrownError, s = r.isStopped;
677    i ? e.error(o) : s && e.complete();
678  }, n.prototype.asObservable = function() {
679    var e = new w();
680    return e.source = this, e;
681  }, n.create = function(e, r) {
682    return new ue(e, r);
683  }, n;
684}(w), ue = function(t) {
685  k(n, t);
686  function n(e, r) {
687    var i = t.call(this) || this;
688    return i.destination = e, i.source = r, i;
689  }
690  return n.prototype.next = function(e) {
691    var r, i;
692    (i = (r = this.destination) === null || r === void 0 ? void 0 : r.next) === null || i === void 0 || i.call(r, e);
693  }, n.prototype.error = function(e) {
694    var r, i;
695    (i = (r = this.destination) === null || r === void 0 ? void 0 : r.error) === null || i === void 0 || i.call(r, e);
696  }, n.prototype.complete = function() {
697    var e, r;
698    (r = (e = this.destination) === null || e === void 0 ? void 0 : e.complete) === null || r === void 0 || r.call(e);
699  }, n.prototype._subscribe = function(e) {
700    var r, i;
701    return (i = (r = this.source) === null || r === void 0 ? void 0 : r.subscribe(e)) !== null && i !== void 0 ? i : ge;
702  }, n;
703}(ie), Xe = function(t) {
704  k(n, t);
705  function n(e) {
706    var r = t.call(this) || this;
707    return r._value = e, r;
708  }
709  return Object.defineProperty(n.prototype, "value", {
710    get: function() {
711      return this.getValue();
712    },
713    enumerable: !1,
714    configurable: !0
715  }), n.prototype._subscribe = function(e) {
716    var r = t.prototype._subscribe.call(this, e);
717    return !r.closed && e.next(this._value), r;
718  }, n.prototype.getValue = function() {
719    var e = this, r = e.hasError, i = e.thrownError, o = e._value;
720    if (r)
721      throw i;
722    return this._throwIfClosed(), o;
723  }, n.prototype.next = function(e) {
724    t.prototype.next.call(this, this._value = e);
725  }, n;
726}(ie), Je = new w(function(t) {
727  return t.complete();
728}), Ne = function(t) {
729  return t && typeof t.length == "number" && typeof t != "function";
730};
731function Ze(t) {
732  return y(t == null ? void 0 : t.then);
733}
734function et(t) {
735  return y(t[re]);
736}
737function tt(t) {
738  return Symbol.asyncIterator && y(t == null ? void 0 : t[Symbol.asyncIterator]);
739}
740function nt(t) {
741  return new TypeError("You provided " + (t !== null && typeof t == "object" ? "an invalid object" : "'" + t + "'") + " where a stream was expected. You can provide an Observable, Promise, ReadableStream, Array, AsyncIterable, or Iterable.");
742}
743function rt() {
744  return typeof Symbol != "function" || !Symbol.iterator ? "@@iterator" : Symbol.iterator;
745}
746var it = rt();
747function ot(t) {
748  return y(t == null ? void 0 : t[it]);
749}
750function st(t) {
751  return $e(this, arguments, function() {
752    var e, r, i, o;
753    return we(this, function(s) {
754      switch (s.label) {
755        case 0:
756          e = t.getReader(), s.label = 1;
757        case 1:
758          s.trys.push([1, , 9, 10]), s.label = 2;
759        case 2:
760          return [4, P(e.read())];
761        case 3:
762          return r = s.sent(), i = r.value, o = r.done, o ? [4, P(void 0)] : [3, 5];
763        case 4:
764          return [2, s.sent()];
765        case 5:
766          return [4, P(i)];
767        case 6:
768          return [4, s.sent()];
769        case 7:
770          return s.sent(), [3, 2];
771        case 8:
772          return [3, 10];
773        case 9:
774          return e.releaseLock(), [7];
775        case 10:
776          return [2];
777      }
778    });
779  });
780}
781function ct(t) {
782  return y(t == null ? void 0 : t.getReader);
783}
784function oe(t) {
785  if (t instanceof w)
786    return t;
787  if (t != null) {
788    if (et(t))
789      return at(t);
790    if (Ne(t))
791      return ut(t);
792    if (Ze(t))
793      return ft(t);
794    if (tt(t))
795      return _e(t);
796    if (ot(t))
797      return lt(t);
798    if (ct(t))
799      return dt(t);
800  }
801  throw nt(t);
802}
803function at(t) {
804  return new w(function(n) {
805    var e = t[re]();
806    if (y(e.subscribe))
807      return e.subscribe(n);
808    throw new TypeError("Provided object does not correctly implement Symbol.observable");
809  });
810}
811function ut(t) {
812  return new w(function(n) {
813    for (var e = 0; e < t.length && !n.closed; e++)
814      n.next(t[e]);
815    n.complete();
816  });
817}
818function ft(t) {
819  return new w(function(n) {
820    t.then(function(e) {
821      n.closed || (n.next(e), n.complete());
822    }, function(e) {
823      return n.error(e);
824    }).then(null, xe);
825  });
826}
827function lt(t) {
828  return new w(function(n) {
829    var e, r;
830    try {
831      for (var i = _(t), o = i.next(); !o.done; o = i.next()) {
832        var s = o.value;
833        if (n.next(s), n.closed)
834          return;
835      }
836    } catch (u) {
837      e = { error: u };
838    } finally {
839      try {
840        o && !o.done && (r = i.return) && r.call(i);
841      } finally {
842        if (e)
843          throw e.error;
844      }
845    }
846    n.complete();
847  });
848}
849function _e(t) {
850  return new w(function(n) {
851    ht(t, n).catch(function(e) {
852      return n.error(e);
853    });
854  });
855}
856function dt(t) {
857  return _e(st(t));
858}
859function ht(t, n) {
860  var e, r, i, o;
861  return Ue(this, void 0, void 0, function() {
862    var s, u;
863    return we(this, function(c) {
864      switch (c.label) {
865        case 0:
866          c.trys.push([0, 5, 6, 11]), e = Fe(t), c.label = 1;
867        case 1:
868          return [4, e.next()];
869        case 2:
870          if (r = c.sent(), !!r.done)
871            return [3, 4];
872          if (s = r.value, n.next(s), n.closed)
873            return [2];
874          c.label = 3;
875        case 3:
876          return [3, 1];
877        case 4:
878          return [3, 11];
879        case 5:
880          return u = c.sent(), i = { error: u }, [3, 11];
881        case 6:
882          return c.trys.push([6, , 9, 10]), r && !r.done && (o = e.return) ? [4, o.call(e)] : [3, 8];
883        case 7:
884          c.sent(), c.label = 8;
885        case 8:
886          return [3, 10];
887        case 9:
888          if (i)
889            throw i.error;
890          return [7];
891        case 10:
892          return [7];
893        case 11:
894          return n.complete(), [2];
895      }
896    });
897  });
898}
899var ke = te(function(t) {
900  return function() {
901    t(this), this.name = "EmptyError", this.message = "no elements in sequence";
902  };
903});
904function Te(t, n) {
905  return T(function(e, r) {
906    var i = 0;
907    e.subscribe(x(r, function(o) {
908      r.next(t.call(n, o, i++));
909    }));
910  });
911}
912function pt(t, n, e, r, i, o, s, u) {
913  var c = [], a = 0, d = 0, v = !1, b = function() {
914    v && !c.length && !a && n.complete();
915  }, f = function(l) {
916    return a < r ? h(l) : c.push(l);
917  }, h = function(l) {
918    a++;
919    var m = !1;
920    oe(e(l, d++)).subscribe(x(n, function(p) {
921      n.next(p);
922    }, function() {
923      m = !0;
924    }, void 0, function() {
925      if (m)
926        try {
927          a--;
928          for (var p = function() {
929            var g = c.shift();
930            s || h(g);
931          }; c.length && a < r; )
932            p();
933          b();
934        } catch (g) {
935          n.error(g);
936        }
937    }));
938  };
939  return t.subscribe(x(n, f, function() {
940    v = !0, b();
941  })), function() {
942  };
943}
944function Oe(t, n, e) {
945  return e === void 0 && (e = 1 / 0), y(n) ? Oe(function(r, i) {
946    return Te(function(o, s) {
947      return n(r, o, i, s);
948    })(oe(t(r, i)));
949  }, e) : (typeof n == "number" && (e = n), T(function(r, i) {
950    return pt(r, i, t, e);
951  }));
952}
953function yt(t, n) {
954  return T(function(e, r) {
955    var i = 0;
956    e.subscribe(x(r, function(o) {
957      return t.call(n, o, i++) && r.next(o);
958    }));
959  });
960}
961function vt(t) {
962  return T(function(n, e) {
963    var r = !1;
964    n.subscribe(x(e, function(i) {
965      r = !0, e.next(i);
966    }, function() {
967      r || e.next(t), e.complete();
968    }));
969  });
970}
971function De(t) {
972  return t <= 0 ? function() {
973    return Je;
974  }