(t, e)
| 30474 | return e.addStream(n).id; |
| 30475 | } |
| 30476 | function fO(t, e) { |
| 30477 | let n; |
| 30478 | t.type === sO |
| 30479 | ? ((n = e.event(sO, t.throttle)), |
| 30480 | (t = { between: t.between, filter: t.filter })) |
| 30481 | : (n = e.event( |
| 30482 | (function (t) { |
| 30483 | return t === eO ? nO : t || nO; |
| 30484 | })(t.source), |
| 30485 | t.type, |
| 30486 | )); |
| 30487 | const r = hO({ stream: n }, t, e); |
| 30488 | return 1 === Object.keys(r).length ? n : e.addStream(r).id; |
| 30489 | } |
| 30490 | function hO(t, e, n) { |
| 30491 | let r = e.between; |
| 30492 | return ( |