kefir
Advanced tools
Comparing version 3.8.0 to 3.8.1
@@ -27,3 +27,3 @@ ## Comparison of public APIs of `Bacon v0.7.52` and `Kefir v2.0.0` | ||
| | Use bus | `Kefir.emitter()` | | | ||
| | `Bacon.fromBinder(subscribe)` | `Kefir.stream(subscribe)` | In Kefir [emitter](https://rpominov.github.io/kefir/#emitter-object) is used unlike `sink` function in Bacon. In Kefir there is no feature "The sink function may return Bacon.noMore ..." | | ||
| | `Bacon.fromBinder(subscribe)` | `Kefir.stream(subscribe)` | In Kefir [emitter](https://kefirjs.github.io/kefir/#emitter-object) is used unlike `sink` function in Bacon. In Kefir there is no feature "The sink function may return Bacon.noMore ..." | | ||
| | No alt. | `Kefir.withInterval(interval, handler)` | | | ||
@@ -30,0 +30,0 @@ |
134
changelog.md
| ## 3.8.0 (27/10/2017) | ||
| - New method `.thru` [#thru](https://github.com/rpominov/kefir/pull/257) [@mAAdhaTTah](https://github.com/mAAdhaTTah) | ||
| - New method `.thru` [#257](https://github.com/kefirjs/kefir/pull/257) [@mAAdhaTTah](https://github.com/mAAdhaTTah) | ||
| ## 3.7.4 (25/08/2017) | ||
| - A bug `.take` / `.takeErrors` was fixed [#244](https://github.com/rpominov/kefir/pull/244) [@mAAdhaTTah](https://github.com/mAAdhaTTah) | ||
| - A bug in `.take` / `.takeErrors` was fixed [#244](https://github.com/kefirjs/kefir/pull/244) [@mAAdhaTTah](https://github.com/mAAdhaTTah) | ||
| ## 3.7.3 (17/07/2017) | ||
| - A bug in Flow definitions was fixed [#245](https://github.com/rpominov/kefir/issues/245) | ||
| - A bug in Flow definitions was fixed [#245](https://github.com/kefirjs/kefir/issues/245) | ||
| ## 3.7.2 (27/05/2017) | ||
| - Flow definitions improved [#242](https://github.com/rpominov/kefir/pull/242) [@hallettj](https://github.com/hallettj) | ||
| - Flow definitions improved [#242](https://github.com/kefirjs/kefir/pull/242) [@hallettj](https://github.com/hallettj) | ||
| ## 3.7.1 (21/01/2017) | ||
| - The `.setName` method has been added to Flow definitions [#232](https://github.com/rpominov/kefir/pull/232) [@mAAdhaTTah](https://github.com/mAAdhaTTah) | ||
| - The `.setName` method has been added to Flow definitions [#232](https://github.com/kefirjs/kefir/pull/232) [@mAAdhaTTah](https://github.com/mAAdhaTTah) | ||
| ## 3.7.0 (31/12/2016) | ||
| - The `.combine` method now can also accept objects instead of arrays [#225](https://github.com/rpominov/kefir/pull/225) [@32bitkid](https://github.com/32bitkid) | ||
| - The `.combine` method now can also accept objects instead of arrays [#225](https://github.com/kefirjs/kefir/pull/225) [@32bitkid](https://github.com/32bitkid) | ||
| ## 3.6.1 (29/11/2016) | ||
| - Flow definitions fixed and updated to be compatible with Flow 0.36 [#229](https://github.com/rpominov/kefir/pull/229) [@AgentME](https://github.com/AgentME) | ||
| - Flow definitions fixed and updated to be compatible with Flow 0.36 [#229](https://github.com/kefirjs/kefir/pull/229) [@AgentME](https://github.com/AgentME) | ||
| ## 3.6.0 (19/10/2016) | ||
| - New methods `.spy` and `.offSpy` [#222](https://github.com/rpominov/kefir/pull/222) [@32bitkid](https://github.com/32bitkid) | ||
| - New methods `.spy` and `.offSpy` [#222](https://github.com/kefirjs/kefir/pull/222) [@32bitkid](https://github.com/32bitkid) | ||
| ## 3.5.2 (07/10/2016) | ||
| - Flow definition for `flatMapConcurLimit` fixed [#221](https://github.com/rpominov/kefir/pull/221) [@32bitkid](https://github.com/32bitkid) | ||
| - Flow definition for `flatMapConcurLimit` fixed [#221](https://github.com/kefirjs/kefir/pull/221) [@32bitkid](https://github.com/32bitkid) | ||
| ## 3.5.1 (29/08/2016) | ||
| - `.filter(Bolean)` support in Flow definitions [#218](https://github.com/rpominov/kefir/pull/218) [@AgentME](https://github.com/AgentME) | ||
| - `.filter(Bolean)` support in Flow definitions [#218](https://github.com/kefirjs/kefir/pull/218) [@AgentME](https://github.com/AgentME) | ||
| ## 3.5.0 (29/08/2016) | ||
| - Flow types are now included in NPM package [#217](https://github.com/rpominov/kefir/pull/217) [@AgentME](https://github.com/AgentME) | ||
| - Flow types are now included in NPM package [#217](https://github.com/kefirjs/kefir/pull/217) [@AgentME](https://github.com/AgentME) | ||
| ## 3.4.0 (17/08/2016) | ||
| - [Static Land](https://github.com/rpominov/static-land) support added. | ||
| - [Static Land](https://github.com/kefirjs/static-land) support added. | ||
| ## 3.3.0 (16/07/2016) | ||
| - New method `.observe` [#151](https://github.com/rpominov/kefir/issues/151) [#221](https://github.com/rpominov/kefir/pull/211) [@mAAdhaTTah](https://github.com/mAAdhaTTah) | ||
| - New method `.observe` [#151](https://github.com/kefirjs/kefir/issues/151) [#221](https://github.com/kefirjs/kefir/pull/211) [@mAAdhaTTah](https://github.com/mAAdhaTTah) | ||
| - Emitter methods renamed `emit → value`, `emitEvent → event` (old names will work as well for now) | ||
@@ -56,18 +56,18 @@ | ||
| - `stream[Symbol.observable]().subscribe()` now returns an object instead of `unsub` function [#212](https://github.com/rpominov/kefir/pull/212) | ||
| - `stream[Symbol.observable]().subscribe` now supports `subscribe(onValue, onError, onComplete)` format [27192e6](https://github.com/rpominov/kefir/commit/27192e6af06aa1e94eb0bd41a8ad633f2f88a09a) | ||
| - `stream[Symbol.observable]().subscribe()` now returns an object instead of `unsub` function [#212](https://github.com/kefirjs/kefir/pull/212) | ||
| - `stream[Symbol.observable]().subscribe` now supports `subscribe(onValue, onError, onComplete)` format [27192e6](https://github.com/kefirjs/kefir/commit/27192e6af06aa1e94eb0bd41a8ad633f2f88a09a) | ||
| ## 3.2.5 (4/07/2016) | ||
| - `stream[Symbol.observable]` now equals to `stream[Symbol.observable][Symbol.observable]` [#209](https://github.com/rpominov/kefir/pull/209) [#210](https://github.com/rpominov/kefir/pull/210) [@mAAdhaTTah](https://github.com/mAAdhaTTah) | ||
| - `stream[Symbol.observable]` now equals to `stream[Symbol.observable][Symbol.observable]` [#209](https://github.com/kefirjs/kefir/pull/209) [#210](https://github.com/kefirjs/kefir/pull/210) [@mAAdhaTTah](https://github.com/mAAdhaTTah) | ||
| ## 3.2.3 (20/05/2016) | ||
| - .babelrc added to .npmignore [#203](https://github.com/rpominov/kefir/pull/203) [@aksonov](https://github.com/aksonov) | ||
| - .babelrc added to .npmignore [#203](https://github.com/kefirjs/kefir/pull/203) [@aksonov](https://github.com/aksonov) | ||
| ## 3.2.2 (26/04/2016) | ||
| - Deprecation warnings disabling API fixed [#185](https://github.com/rpominov/kefir/issues/185) | ||
| - A bug in `.bufferWithTimeOrCount` is fixed [#194](https://github.com/rpominov/kefir/issues/194) | ||
| - Switched to `symbol-observable` [#200](https://github.com/rpominov/kefir/pull/200) [@blesh](https://github.com/blesh) | ||
| - Deprecation warnings disabling API fixed [#185](https://github.com/kefirjs/kefir/issues/185) | ||
| - A bug in `.bufferWithTimeOrCount` is fixed [#194](https://github.com/kefirjs/kefir/issues/194) | ||
| - Switched to `symbol-observable` [#200](https://github.com/kefirjs/kefir/pull/200) [@blesh](https://github.com/blesh) | ||
@@ -84,27 +84,27 @@ ## 3.2.1 (25/02/2016) | ||
| Big thanks to [@rvikmanis](https://github.com/rvikmanis) for doing this. [#184](https://github.com/rpominov/kefir/pull/184) | ||
| Big thanks to [@rvikmanis](https://github.com/rvikmanis) for doing this. [#184](https://github.com/kefirjs/kefir/pull/184) | ||
| ## 3.2.0 (12/12/2015) | ||
| - New method `.bufferWithTimeOrCount` [#172](https://github.com/rpominov/kefir/pull/172) [@mcmathja](https://github.com/mcmathja) | ||
| - New method `.bufferWithCount` [#170](https://github.com/rpominov/kefir/pull/170) [@elsehow](https://github.com/elsehow) | ||
| - New method `.bufferWithTimeOrCount` [#172](https://github.com/kefirjs/kefir/pull/172) [@mcmathja](https://github.com/mcmathja) | ||
| - New method `.bufferWithCount` [#170](https://github.com/kefirjs/kefir/pull/170) [@elsehow](https://github.com/elsehow) | ||
| ## 3.1.0 (5/10/2015) | ||
| - Interoperation with [ECMAScript Observables](https://github.com/zenparsing/es-observable) added with two new methods: `.fromESObservable` and `.toESObservable`/`[Symbol.observable]` [#154](https://github.com/rpominov/kefir/pull/154) [@lautis](https://github.com/lautis) | ||
| - A bug in `.fromEvents` fixed [#159](https://github.com/rpominov/kefir/issues/159) | ||
| - Interoperation with [ECMAScript Observables](https://github.com/zenparsing/es-observable) added with two new methods: `.fromESObservable` and `.toESObservable`/`[Symbol.observable]` [#154](https://github.com/kefirjs/kefir/pull/154) [@lautis](https://github.com/lautis) | ||
| - A bug in `.fromEvents` fixed [#159](https://github.com/kefirjs/kefir/issues/159) | ||
| ## 3.0.0 (26/09/2015) | ||
| - All previously deprecated methods removed. Full list can be found in [deprecated API docs of v2.x](https://github.com/rpominov/kefir/blob/v2/deprecated-api-docs.md). | ||
| - New deprecations: [errorsToValues & valuesToErrors](https://github.com/rpominov/kefir/issues/149), [endOnError](https://github.com/rpominov/kefir/issues/150), [awaiting](https://github.com/rpominov/kefir/issues/145). | ||
| - New method `.takeErrors` replacing deprecated `.endOnError` [#150](https://github.com/rpominov/kefir/issues/150) | ||
| - Methods `.skipValues`, `.skipErrors`, and `.skipEnd` are renamed to `.ignoreValues`, `.ignoreErrors`, and `.ignoreEnd` [#152](https://github.com/rpominov/kefir/issues/152) | ||
| - The `emitEmpty` option from `.bufferWhileBy` removed, it now always emits `[]` if necessary [#131](https://github.com/rpominov/kefir/issues/131) | ||
| - Property now sets its current value **before** dispatching [#127](https://github.com/rpominov/kefir/issues/127) [@olivierguerriat](https://github.com/olivierguerriat) | ||
| - Event objects now don't contain `.current` property [#100](https://github.com/rpominov/kefir/issues/100) | ||
| - The `.flatten` method now always returns a stream [#144](https://github.com/rpominov/kefir/issues/144) | ||
| - All previously deprecated methods removed. Full list can be found in [deprecated API docs of v2.x](https://github.com/kefirjs/kefir/blob/v2/deprecated-api-docs.md). | ||
| - New deprecations: [errorsToValues & valuesToErrors](https://github.com/kefirjs/kefir/issues/149), [endOnError](https://github.com/kefirjs/kefir/issues/150), [awaiting](https://github.com/kefirjs/kefir/issues/145). | ||
| - New method `.takeErrors` replacing deprecated `.endOnError` [#150](https://github.com/kefirjs/kefir/issues/150) | ||
| - Methods `.skipValues`, `.skipErrors`, and `.skipEnd` are renamed to `.ignoreValues`, `.ignoreErrors`, and `.ignoreEnd` [#152](https://github.com/kefirjs/kefir/issues/152) | ||
| - The `emitEmpty` option from `.bufferWhileBy` removed, it now always emits `[]` if necessary [#131](https://github.com/kefirjs/kefir/issues/131) | ||
| - Property now sets its current value **before** dispatching [#127](https://github.com/kefirjs/kefir/issues/127) [@olivierguerriat](https://github.com/olivierguerriat) | ||
| - Event objects now don't contain `.current` property [#100](https://github.com/kefirjs/kefir/issues/100) | ||
| - The `.flatten` method now always returns a stream [#144](https://github.com/kefirjs/kefir/issues/144) | ||
| See also [Umbrella 3.0](https://github.com/rpominov/kefir/issues/138) | ||
| See also [Umbrella 3.0](https://github.com/kefirjs/kefir/issues/138) | ||
@@ -114,29 +114,29 @@ | ||
| - A bug in `.scan` fixed [#148](https://github.com/rpominov/kefir/issues/148) | ||
| - A bug in `.scan` fixed [#148](https://github.com/kefirjs/kefir/issues/148) | ||
| ## 2.8.1 (30/08/2015) | ||
| - A bug in `.delay` fixed [#134](https://github.com/rpominov/kefir/issues/134) [@AgentME](https://github.com/AgentME) | ||
| - A bug in `.delay` fixed [#134](https://github.com/kefirjs/kefir/issues/134) [@AgentME](https://github.com/AgentME) | ||
| ## 2.8.0 (21/08/2015) | ||
| - The `emitEmpty` option added to `.bufferWhileBy` [#129](https://github.com/rpominov/kefir/pull/129) [@shamansir](https://github.com/shamansir) | ||
| - The `emitEmpty` option added to `.bufferWhileBy` [#129](https://github.com/kefirjs/kefir/pull/129) [@shamansir](https://github.com/shamansir) | ||
| ## 2.7.2 (16/07/2015) | ||
| - A bug related to calling `emitter.end()` in response to an end event or in `unsubscribe()` function is fixed [83b06a7](https://github.com/rpominov/kefir/commit/83b06a7debb553dd7fd21c407c49b45da3e1b0ea) | ||
| - A bug related to calling `emitter.end()` in response to an end event or in `unsubscribe()` function is fixed [83b06a7](https://github.com/kefirjs/kefir/commit/83b06a7debb553dd7fd21c407c49b45da3e1b0ea) | ||
| ## 2.7.1 (11/07/2015) | ||
| - A bug when listener could be called after unsubscribing or end is fixed [#119](https://github.com/rpominov/kefir/issues/119) | ||
| - A bug when listener could be called after unsubscribing or end is fixed [#119](https://github.com/kefirjs/kefir/issues/119) | ||
| ## 2.7.0 (27/06/2015) | ||
| - The `flushOnChange` option added to `.bufferWhileBy` [#116](https://github.com/rpominov/kefir/issues/116) | ||
| - The `flushOnChange` option added to `.bufferWhileBy` [#116](https://github.com/kefirjs/kefir/issues/116) | ||
| ## 2.6.0 (05/06/2015) | ||
| - A bug in `.bufferBy` fixed [#108](https://github.com/rpominov/kefir/issues/108) | ||
| - Another (minor) perf improvement for `flatMap` and similar methods [c329c61](https://github.com/rpominov/kefir/commit/c329c61c4869a550e2b29eaa9ab6c7d4a7e899ad) | ||
| - The `.toProperty` method now throws with a meaningful message when called with not a function [544b689](https://github.com/rpominov/kefir/commit/544b689d9ffd165d09f3d04de8c40a4b59ceb04c) | ||
| - A bug in `.bufferBy` fixed [#108](https://github.com/kefirjs/kefir/issues/108) | ||
| - Another (minor) perf improvement for `flatMap` and similar methods [c329c61](https://github.com/kefirjs/kefir/commit/c329c61c4869a550e2b29eaa9ab6c7d4a7e899ad) | ||
| - The `.toProperty` method now throws with a meaningful message when called with not a function [544b689](https://github.com/kefirjs/kefir/commit/544b689d9ffd165d09f3d04de8c40a4b59ceb04c) | ||
@@ -146,5 +146,5 @@ ## 2.5.0 (21/05/2015) | ||
| - The repository moved from `pozadi/kefir` to `rpominov/kefir` | ||
| - [emitter](http://rpominov.github.io/kefir/#emitter-object) methods now return a boolean representing whether anybody interested in future events (i.e. whether connected observable is active) | ||
| - Another optimization for `.flatMap((x) => Kefir.constan(...))` case [9e4a58a](https://github.com/rpominov/kefir/commit/9e4a58a02ec5f80b3c3c6cf52e5e5065249aba50) | ||
| - Methods `.takeWhileBy` and `.skipWhileBy` are deprecated [#105](https://github.com/rpominov/kefir/issues/105) | ||
| - [emitter](http://kefirjs.github.io/kefir/#emitter-object) methods now return a boolean representing whether anybody interested in future events (i.e. whether connected observable is active) | ||
| - Another optimization for `.flatMap((x) => Kefir.constan(...))` case [9e4a58a](https://github.com/kefirjs/kefir/commit/9e4a58a02ec5f80b3c3c6cf52e5e5065249aba50) | ||
| - Methods `.takeWhileBy` and `.skipWhileBy` are deprecated [#105](https://github.com/kefirjs/kefir/issues/105) | ||
@@ -158,4 +158,4 @@ ## 2.4.1 (14/05/2015) | ||
| - New method `.flatMapErrors` | ||
| - A bug in `.flatMap*` fixed [98f65b7](https://github.com/rpominov/kefir/commit/98f65b775e2a9785bb66fa1f4a98ffc9bd03b9ff) | ||
| - `Kefir.constant()` and `Kefir.contantError()` made cheaper and faster, so they can be used with `.flatMap` even more freely [1c9de75](https://github.com/rpominov/kefir/commit/1c9de75aa7ed38949716b9d117b430587bd3425c) | ||
| - A bug in `.flatMap*` fixed [98f65b7](https://github.com/kefirjs/kefir/commit/98f65b775e2a9785bb66fa1f4a98ffc9bd03b9ff) | ||
| - `Kefir.constant()` and `Kefir.contantError()` made cheaper and faster, so they can be used with `.flatMap` even more freely [1c9de75](https://github.com/kefirjs/kefir/commit/1c9de75aa7ed38949716b9d117b430587bd3425c) | ||
@@ -173,3 +173,3 @@ ## 2.3.0 (10/05/2015) | ||
| - Codebase ported to ES6 (Babel) with CommonJS modules | ||
| - A bug in .combine fixed [#98](https://github.com/rpominov/kefir/issues/98) | ||
| - A bug in .combine fixed [#98](https://github.com/kefirjs/kefir/issues/98) | ||
@@ -183,3 +183,3 @@ ## 2.1.0 (28/04/2015) | ||
| - A bug in `.flatMap` fixed [#92](https://github.com/rpominov/kefir/issues/92) | ||
| - A bug in `.flatMap` fixed [#92](https://github.com/kefirjs/kefir/issues/92) | ||
@@ -190,23 +190,23 @@ ## 2.0.0 (22/04/2015) | ||
| - Removed support of old transducers protocol in the `.transduce` [#79](https://github.com/rpominov/kefir/issues/79) | ||
| - `stream.changes()` now returns a new stream with current values/errors removed [#56](https://github.com/rpominov/kefir/issues/56) | ||
| - Properties now can't have both current value and current error at the same time [#55](https://github.com/rpominov/kefir/issues/55) | ||
| - Better errors handling in `.combine` [#54](https://github.com/rpominov/kefir/issues/54) | ||
| - The `.toProperty` method now accepts a callbak instead of a simple value [#82](https://github.com/rpominov/kefir/issues/82) | ||
| - Removed support of old transducers protocol in the `.transduce` [#79](https://github.com/kefirjs/kefir/issues/79) | ||
| - `stream.changes()` now returns a new stream with current values/errors removed [#56](https://github.com/kefirjs/kefir/issues/56) | ||
| - Properties now can't have both current value and current error at the same time [#55](https://github.com/kefirjs/kefir/issues/55) | ||
| - Better errors handling in `.combine` [#54](https://github.com/kefirjs/kefir/issues/54) | ||
| - The `.toProperty` method now accepts a callbak instead of a simple value [#82](https://github.com/kefirjs/kefir/issues/82) | ||
| - The `.fromEvent` method is renamed to `.fromEvents` | ||
| - The `.fromBinder` method is renamed to `.stream` | ||
| - The `.mapEnd` method is renamed to `.beforeEnd` [#89](https://github.com/rpominov/kefir/issues/89) | ||
| - The `.mapEnd` method is renamed to `.beforeEnd` [#89](https://github.com/kefirjs/kefir/issues/89) | ||
| ### Other changes | ||
| - The `.fromSubUnsub` method is deprecated [#71](https://github.com/rpominov/kefir/issues/71) | ||
| - Methods `Kefir.emitter()` and `Kefir.bus()` are deprecated [#88](https://github.com/rpominov/kefir/issues/88) | ||
| - The `.fromSubUnsub` method is deprecated [#71](https://github.com/kefirjs/kefir/issues/71) | ||
| - Methods `Kefir.emitter()` and `Kefir.bus()` are deprecated [#88](https://github.com/kefirjs/kefir/issues/88) | ||
| ## 1.3.2 (26/04/2015) | ||
| - A bug in `.flatMap` fixed [#92](https://github.com/rpominov/kefir/issues/92) | ||
| - A bug in `.flatMap` fixed [#92](https://github.com/kefirjs/kefir/issues/92) | ||
| ## 1.3.1 (04/04/2015) | ||
| - The `.transduce` method updated to add support of new protocol [#78](https://github.com/rpominov/kefir/issues/78) | ||
| - The `.transduce` method updated to add support of new protocol [#78](https://github.com/kefirjs/kefir/issues/78) | ||
@@ -218,3 +218,3 @@ | ||
| `.repeatedly`, `.mapTo`, `.pluck`, `.invoke`, `.not`, `.timestamp`, `.tap`, `.and`, `.or` | ||
| [#71](https://github.com/rpominov/kefir/issues/71) | ||
| [#71](https://github.com/kefirjs/kefir/issues/71) | ||
@@ -234,4 +234,4 @@ ## 1.2.0 (14/03/2015) | ||
| - jQuery plugin moved to a [separate repo](https://github.com/rpominov/kefir-jquery) | ||
| - Minor improvement in .skipDuplicates method [#42](https://github.com/rpominov/kefir/issues/42) | ||
| - jQuery plugin moved to a [separate repo](https://github.com/kefirjs/kefir-jquery) | ||
| - Minor improvement in .skipDuplicates method [#42](https://github.com/kefirjs/kefir/issues/42) | ||
| - Deperecated method .withDefault now removed | ||
@@ -241,7 +241,7 @@ | ||
| - A bug in .fromBinder fixed (continuation of [#35](https://github.com/rpominov/kefir/issues/35) | ||
| - A bug in .fromBinder fixed (continuation of [#35](https://github.com/kefirjs/kefir/issues/35) | ||
| ## 0.5.2 (12/01/2015) | ||
| - A bug in .fromBinder fixed [#35](https://github.com/rpominov/kefir/issues/35) | ||
| - A bug in .fromBinder fixed [#35](https://github.com/kefirjs/kefir/issues/35) | ||
@@ -278,3 +278,3 @@ ## 0.5.1 (08/01/2015) | ||
| - A bug in `.flatMap` fixed [#29](https://github.com/rpominov/kefir/issues/29) | ||
| - A bug in `.flatMap` fixed [#29](https://github.com/kefirjs/kefir/issues/29) | ||
| - Minor perf fixes | ||
@@ -294,3 +294,3 @@ | ||
| - The `seed` argument in `.scan`, `.reduce`, and `.diff` is now optional | ||
| - Removed support of ["array functions"](https://github.com/rpominov/kefir/blob/2edf32a82d5b24ecb6ed99c9bcbd2391b91c8715/docs-src/descriptions/about-callbacks.jade) | ||
| - Removed support of ["array functions"](https://github.com/kefirjs/kefir/blob/2edf32a82d5b24ecb6ed99c9bcbd2391b91c8715/docs-src/descriptions/about-callbacks.jade) | ||
| - The default `fn` in `obs.sampledBy(other, fn)` changed from `function(a, b) {return [a, b]}` to `function(a, b) {return a}`. The default `fn` for `Kefir.sampledBy` hasn't changed. | ||
@@ -297,0 +297,0 @@ - New method `.mapEnd` |
| # Deprecated API Methods documentation | ||
| All documentation on deprecated methods are moved | ||
| from [main docs](http://rpominov.github.io/kefir/) to this file. | ||
| from [main docs](http://kefirjs.github.io/kefir/) to this file. | ||
| See also [2.x's version of this document](https://github.com/rpominov/kefir/blob/v2/deprecated-api-docs.md) containing docs on methods that were removed in 3.0. | ||
| See also [2.x's version of this document](https://github.com/kefirjs/kefir/blob/v2/deprecated-api-docs.md) containing docs on methods that were removed in 3.0. | ||
| ### `obs.awaiting(otherObs)` [#145](https://github.com/rpominov/kefir/issues/145) | ||
| ### `obs.awaiting(otherObs)` [#145](https://github.com/kefirjs/kefir/issues/145) | ||
@@ -42,3 +42,3 @@ Returns a property that represents the awaiting status of two observables, | ||
| ### `obs.valuesToErrors([handler])` [#149](https://github.com/rpominov/kefir/issues/149) | ||
| ### `obs.valuesToErrors([handler])` [#149](https://github.com/kefirjs/kefir/issues/149) | ||
@@ -79,3 +79,3 @@ Converts values to errors. By default it converts all values to errors, | ||
| ### `obs.errorsToValues([handler])` [#149](https://github.com/rpominov/kefir/issues/149) | ||
| ### `obs.errorsToValues([handler])` [#149](https://github.com/kefirjs/kefir/issues/149) | ||
@@ -111,3 +111,3 @@ Same as valuesToErrors but vice versa. | ||
| ### `obs.endOnError()` [#150](https://github.com/rpominov/kefir/issues/150) | ||
| ### `obs.endOnError()` [#150](https://github.com/kefirjs/kefir/issues/150) | ||
@@ -114,0 +114,0 @@ Makes an observable to end on first error. |
@@ -1,5 +0,5 @@ | ||
| /*! Kefir.js v3.8.0 | ||
| * https://github.com/rpominov/kefir | ||
| /*! Kefir.js v3.8.1 | ||
| * https://github.com/kefirjs/kefir | ||
| */ | ||
| !function(t,n){"object"==typeof exports&&"undefined"!=typeof module?n(exports):"function"==typeof define&&define.amd?define(["exports"],n):n(t.Kefir=t.Kefir||{})}(this,function(t){"use strict";function n(t){var n=function(){};return n.prototype=t,new n}function i(t){var n=arguments.length,i=void 0,e=void 0;for(i=1;i<n;i++)for(e in arguments[i])t[e]=arguments[i][e];return t}function e(t,e){var r=arguments.length,s=void 0;for(t.prototype=n(e.prototype),t.prototype.constructor=t,s=2;s<r;s++)i(t.prototype,arguments[s]);return t}function r(t,n){var i=void 0,e=void 0,r=void 0,s=void 0;if(0===t.length)return n;if(0===n.length)return t;for(s=0,i=new Array(t.length+n.length),e=t.length,r=0;r<e;r++,s++)i[s]=t[r];for(e=n.length,r=0;r<e;r++,s++)i[s]=n[r];return i}function s(t,n){var i=t.length,e=void 0;for(e=0;e<i;e++)if(t[e]===n)return e;return-1}function u(t,n){var i=t.length,e=void 0;for(e=0;e<i;e++)if(n(t[e]))return e;return-1}function o(t){var n=t.length,i=new Array(n),e=void 0;for(e=0;e<n;e++)i[e]=t[e];return i}function a(t,n){var i=t.length,e=void 0,r=void 0,s=void 0;if(n>=0&&n<i){if(1===i)return[];for(e=new Array(i-1),r=0,s=0;r<i;r++)r!==n&&(e[s]=t[r],s++);return e}return t}function h(t,n){var i=t.length,e=new Array(i),r=void 0;for(r=0;r<i;r++)e[r]=n(t[r]);return e}function l(t,n){var i=t.length,e=void 0;for(e=0;e<i;e++)n(t[e])}function _(t,n){var i=t.length,e=void 0;for(e=0;e<i;e++)t[e]=n}function f(t,n){return-1!==s(t,n)}function c(t,n,i){var e=Math.min(i,t.length+1),r=t.length-e+1,s=new Array(e),u=void 0;for(u=r;u<e;u++)s[u-r]=t[u];return s[e-1]=n,s}function d(t,n,i){t===hn?n(i):t===i.type&&(t===on||t===an?n(i.value):n())}function v(){this._items=[],this._spies=[],this._inLoop=0,this._removedItems=null}function p(){this._dispatcher=new v,this._active=!1,this._alive=!0,this._activating=!1,this._logHandlers=null,this._spyHandlers=null}function m(){p.call(this)}function y(){p.call(this),this._currentEvent=null}function g(){return ln}function E(t){function n(t,n){var i=this;m.call(this),this._wait=t,this._intervalId=null,this._$onTick=function(){return i._onTick()},this._init(n)}return e(n,m,{_init:function(){},_free:function(){},_onTick:function(){},_onActivation:function(){this._intervalId=setInterval(this._$onTick,this._wait)},_onDeactivation:function(){null!==this._intervalId&&(clearInterval(this._intervalId),this._intervalId=null)},_clear:function(){m.prototype._clear.call(this),this._$onTick=null,this._free()}},t),n}function b(t,n){return new _n(t,{x:n})}function A(t,n){return new fn(t,{x:n})}function w(t,n){return 0===n.length?g():new cn(t,{xs:n})}function S(t,n){return new dn(t,{fn:n})}function V(t){function n(n){return t._emitValue(n),t._active}function i(n){return t._emitError(n),t._active}function e(){return t._emitEnd(),t._active}function r(n){return t._emit(n.type,n.value),t._active}return{value:n,error:i,end:e,event:r,emit:n,emitEvent:r}}function T(t,n){return new vn(t,{fn:n})}function $(t){m.call(this),this._fn=t,this._unsubscribe=null}function C(t){return new $(t)}function k(t){var n=!1;return C(function(i){n||(t(function(t){i.emit(t),i.end()}),n=!0)}).setName("fromCallback")}function O(t){var n=!1;return C(function(i){n||(t(function(t,n){t?i.error(t):i.emit(n),i.end()}),n=!0)}).setName("fromNodeCallback")}function I(t,n){switch(n){case 0:return function(){return t()};case 1:return function(n){return t(n[0])};case 2:return function(n){return t(n[0],n[1])};case 3:return function(n){return t(n[0],n[1],n[2])};case 4:return function(n){return t(n[0],n[1],n[2],n[3])};default:return function(n){return t.apply(null,n)}}}function x(t,n,i){var e=i?i.length:0;if(null==n)switch(e){case 0:return t();case 1:return t(i[0]);case 2:return t(i[0],i[1]);case 3:return t(i[0],i[1],i[2]);case 4:return t(i[0],i[1],i[2],i[3]);default:return t.apply(null,i)}else switch(e){case 0:return t.call(n);default:return t.apply(n,i)}}function L(t,n,i){return C(function(e){var r=i?function(){e.emit(x(i,this,arguments))}:function(t){e.emit(t)};return t(r),function(){return n(r)}}).setName("fromSubUnsub")}function P(t,n,i){for(var e=void 0,r=void 0,s=0;s<pn.length;s++)if("function"==typeof t[pn[s][0]]&&"function"==typeof t[pn[s][1]]){e=pn[s][0],r=pn[s][1];break}if(void 0===e)throw new Error("target don't support any of addEventListener/removeEventListener, addListener/removeListener, on/off method pair");return L(function(i){return t[e](n,i)},function(i){return t[r](n,i)},i).setName("fromEvents")}function H(t){this._currentEvent={type:"value",value:t,current:!0}}function M(t){return new H(t)}function D(t){this._currentEvent={type:"error",value:t,current:!0}}function N(t){return new D(t)}function q(t,n){return function(i,e){var r=this;t.call(this),this._source=i,this._name=i._name+"."+n,this._init(e),this._$handleAny=function(t){return r._handleAny(t)}}}function W(t){return{_init:function(){},_free:function(){},_handleValue:function(t){this._emitValue(t)},_handleError:function(t){this._emitError(t)},_handleEnd:function(){this._emitEnd()},_handleAny:function(t){switch(t.type){case on:return this._handleValue(t.value);case an:return this._handleError(t.value);case un:return this._handleEnd()}},_onActivation:function(){this._source.onAny(this._$handleAny)},_onDeactivation:function(){this._source.offAny(this._$handleAny)},_clear:function(){t.prototype._clear.call(this),this._source=null,this._$handleAny=null,this._free()}}}function B(t,n){var i=q(m,t);return e(i,m,W(m),n),i}function j(t,n){var i=q(y,t);return e(i,y,W(y),n),i}function U(t){var n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:null;if(null!==n&&"function"!=typeof n)throw new Error("You should call toProperty() with a function or no arguments.");return new mn(t,{fn:n})}function F(t){return new yn(t)}function Q(t){var n=!1;return U(C(function(i){if(!n){var e=function(t){i.emit(t),i.end()},r=function(t){i.error(t),i.end()},s=t.then(e,r);s&&"function"==typeof s.done&&s.done(),n=!0}}),null).setName("fromPromise")}function z(){if("function"==typeof Promise)return Promise;throw new Error("There isn't default Promise, use shim or parameter")}function Y(t,n){return n={exports:{}},t(n,n.exports),n.exports}function K(t){var n=t[Sn]?t[Sn]():t;return C(function(t){var i=n.subscribe({error:function(n){t.error(n),t.end()},next:function(n){t.emit(n)},complete:function(){t.end()}});return i.unsubscribe?function(){i.unsubscribe()}:i}).setName("fromESObservable")}function G(t){this._observable=t.takeErrors(1)}function J(){return new G(this)}function R(t,n,i){for(var e in t)t.hasOwnProperty(e)&&(n.push(e),i.push(t[e]))}function X(t){for(var n=void 0,i=0;i<t.length;i++)void 0!==t[i]&&(void 0===n||n.index<t[i].index)&&(n=t[i]);return n.error}function Z(t,n,i){var e=this;m.call(this),this._activeCount=t.length,this._sources=r(t,n),this._combinator=i,this._aliveCount=0,this._latestValues=new Array(this._sources.length),this._latestErrors=new Array(this._sources.length),_(this._latestValues,sn),this._emitAfterActivation=!1,this._endAfterActivation=!1,this._latestErrorIndex=0,this._$handlers=[];for(var s=0;s<this._sources.length;s++)!function(t){e._$handlers.push(function(n){return e._handleAny(t,n)})}(s)}function tt(t){var n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:[],i=arguments[2];if(!Array.isArray(n))throw new Error("Combine can only combine active and passive collections of the same type.");return i=i?I(i,t.length+n.length):function(t){return t},0===t.length?g():new Z(t,n,i)}function nt(t){var n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:{},i=arguments[2];if("object"!=typeof n||Array.isArray(n))throw new Error("Combine can only combine active and passive collections of the same type.");var e=[],r=[],s=[];R(t,e,r),R(n,e,s);var u=function(t){for(var n={},r=t.length-1;0<=r;r--)n[e[r]]=t[r];return i?i(n):n};return 0===r.length?g():new Z(r,s,u)}function it(t,n,i){return"function"==typeof n&&(i=n,n=void 0),Array.isArray(t)?tt(t,n,i):nt(t,n,i)}function et(t){var n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:On;return new(t._ofSameType(Cn,kn))(t,{fn:n})}function rt(t){var n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:Pn;return new(t._ofSameType(xn,Ln))(t,{fn:n})}function st(t,n){return new(t._ofSameType(Mn,Dn))(t,{n:n})}function ut(t,n){return new(t._ofSameType(qn,Wn))(t,{n:n})}function ot(t){var n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:Fn;return new(t._ofSameType(jn,Un))(t,{fn:n})}function at(t){return new(t._ofSameType(zn,Yn))(t)}function ht(t,n){return new(t._ofSameType(Gn,Jn))(t,{n:n})}function lt(t){var n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:ti;return new(t._ofSameType(Xn,Zn))(t,{fn:n})}function _t(t){var n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:ri;return new(t._ofSameType(ii,ei))(t,{fn:n})}function ft(t,n){return[t,n]}function ct(t,n){var i=arguments.length>2&&void 0!==arguments[2]?arguments[2]:sn;return new(t._ofSameType(ui,oi))(t,{fn:n||ft,seed:i})}function dt(t,n){var i=arguments.length>2&&void 0!==arguments[2]?arguments[2]:sn;return new ai(t,{fn:n,seed:i})}function vt(t){var n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:_i;return new li(t,{fn:n})}function pt(t,n){return new(t._ofSameType(di,vi))(t,{wait:n})}function mt(t,n){var i=arguments.length>2&&void 0!==arguments[2]?arguments[2]:{},e=i.leading,r=void 0===e||e,s=i.trailing,u=void 0===s||s;return new(t._ofSameType(yi,gi))(t,{wait:n,leading:r,trailing:u})}function yt(t,n){var i=arguments.length>2&&void 0!==arguments[2]?arguments[2]:{},e=i.immediate,r=void 0!==e&&e;return new(t._ofSameType(bi,Ai))(t,{wait:n,immediate:r})}function gt(t){var n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:Ti;return new(t._ofSameType(Si,Vi))(t,{fn:n})}function Et(t){var n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:Oi;return new(t._ofSameType(Ci,ki))(t,{fn:n})}function bt(t){return new(t._ofSameType(xi,Li))(t)}function At(t){return new(t._ofSameType(Hi,Mi))(t)}function wt(t){return new(t._ofSameType(Ni,qi))(t)}function St(t,n){return new(t._ofSameType(Bi,ji))(t,{fn:n})}function Vt(t,n){var i=arguments.length>2&&void 0!==arguments[2]?arguments[2]:0;return new(t._ofSameType(Fi,Qi))(t,{min:i,max:n})}function Tt(t,n){var i=arguments.length>2&&void 0!==arguments[2]?arguments[2]:{},e=i.flushOnEnd,r=void 0===e||e;return new(t._ofSameType(Yi,Ki))(t,{fn:n||Gi,flushOnEnd:r})}function $t(t,n){var i=arguments.length>2&&void 0!==arguments[2]?arguments[2]:{},e=i.flushOnEnd,r=void 0===e||e;return new(t._ofSameType(Ri,Xi))(t,{count:n,flushOnEnd:r})}function Ct(t,n,i){var e=arguments.length>3&&void 0!==arguments[3]?arguments[3]:{},r=e.flushOnEnd,s=void 0===r||r;return new(t._ofSameType(te,ne))(t,{wait:n,count:i,flushOnEnd:s})}function kt(t){return{"@@transducer/step":function(n,i){return t._emitValue(i),null},"@@transducer/result":function(){return t._emitEnd(),null}}}function Ot(t,n){return new(t._ofSameType(ee,re))(t,{transducer:n})}function It(t,n){return new(t._ofSameType(ue,oe))(t,{fn:n})}function xt(t,n){var i=this;m.call(this),this._buffers=h(t,function(t){return ae(t)?o(t):[]}),this._sources=h(t,function(t){return ae(t)?g():t}),this._combinator=n?I(n,this._sources.length):function(t){return t},this._aliveCount=0,this._$handlers=[];for(var e=0;e<this._sources.length;e++)!function(t){i._$handlers.push(function(n){return i._handleAny(t,n)})}(e)}function Lt(t,n){return 0===t.length?g():new xt(t,n)}function Pt(){var t=this,n=arguments.length>0&&void 0!==arguments[0]?arguments[0]:{},i=n.queueLim,e=void 0===i?0:i,r=n.concurLim,s=void 0===r?-1:r,u=n.drop,o=void 0===u?"new":u;m.call(this),this._queueLim=e<0?-1:e,this._concurLim=s<0?-1:s,this._drop=o,this._queue=[],this._curSources=[],this._$handleSubAny=function(n){return t._handleSubAny(n)},this._$endHandlers=[],this._currentlyAdding=null,0===this._concurLim&&this._emitEnd()}function Ht(t){Pt.call(this),this._addAll(t),this._initialised=!0}function Mt(t){return 0===t.length?g():new Ht(t)}function Dt(t){var n=this;m.call(this),this._generator=t,this._source=null,this._inLoop=!1,this._iteration=0,this._$handleAny=function(t){return n._handleAny(t)}}function Nt(t){return le(function(n){return t.length>n&&t[n]}).setName("concat")}function qt(){Pt.call(this)}function Wt(t,n,i){var e=this;Pt.call(this,i),this._source=t,this._fn=n,this._mainEnded=!1,this._lastCurrent=null,this._$handleMain=function(t){return e._handleMain(t)}}function Bt(t,n){Wt.call(this,t,n)}function jt(t,n){return function(i,e,r){var s=this;t.call(this),this._primary=i,this._secondary=e,this._name=i._name+"."+n,this._lastSecondary=sn,this._$handleSecondaryAny=function(t){return s._handleSecondaryAny(t)},this._$handlePrimaryAny=function(t){return s._handlePrimaryAny(t)},this._init(r)}}function Ut(t){return{_init:function(){},_free:function(){},_handlePrimaryValue:function(t){this._emitValue(t)},_handlePrimaryError:function(t){this._emitError(t)},_handlePrimaryEnd:function(){this._emitEnd()},_handleSecondaryValue:function(t){this._lastSecondary=t},_handleSecondaryError:function(t){this._emitError(t)},_handleSecondaryEnd:function(){},_handlePrimaryAny:function(t){switch(t.type){case on:return this._handlePrimaryValue(t.value);case an:return this._handlePrimaryError(t.value);case un:return this._handlePrimaryEnd(t.value)}},_handleSecondaryAny:function(t){switch(t.type){case on:return this._handleSecondaryValue(t.value);case an:return this._handleSecondaryError(t.value);case un:this._handleSecondaryEnd(t.value),this._removeSecondary()}},_removeSecondary:function(){null!==this._secondary&&(this._secondary.offAny(this._$handleSecondaryAny),this._$handleSecondaryAny=null,this._secondary=null)},_onActivation:function(){null!==this._secondary&&this._secondary.onAny(this._$handleSecondaryAny),this._active&&this._primary.onAny(this._$handlePrimaryAny)},_onDeactivation:function(){null!==this._secondary&&this._secondary.offAny(this._$handleSecondaryAny),this._primary.offAny(this._$handlePrimaryAny)},_clear:function(){t.prototype._clear.call(this),this._primary=null,this._secondary=null,this._lastSecondary=null,this._$handleSecondaryAny=null,this._$handlePrimaryAny=null,this._free()}}}function Ft(t,n){var i=jt(m,t);return e(i,m,Ut(m),n),i}function Qt(t,n){var i=jt(y,t);return e(i,y,Ut(y),n),i}function zt(t,n){return new(t._ofSameType(fe,ce))(t,n)}function Yt(t,n,i){return it([n],[t],i?function(t,n){return i(n,t)}:de).setName(t,"sampledBy")}function Kt(t,n){return new(t._ofSameType(pe,me))(t,n)}function Gt(t,n){return new(t._ofSameType(ge,Ee))(t,n)}function Jt(t,n,i){return new(t._ofSameType(Ae,we))(t,n,i)}function Rt(t,n,i){return new(t._ofSameType(Ve,Te))(t,n,i)}function Xt(t,n){var i=Mt([et(t,Ce),et(n,$e)]);return i=_t(i),i=U(i,$e),i.setName(t,"awaiting")}function Zt(t){var n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:xe;return new(t._ofSameType(Oe,Ie))(t,{fn:n})}function tn(t){var n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:Me;return new(t._ofSameType(Pe,He))(t,{fn:n})}function nn(t){return new(t._ofSameType(Ne,qe))(t)}function en(){Be=!1}function rn(t){if(Be&&console&&"function"==typeof console.warn){console.warn(t,"\nHere is an Error object for you containing the call stack:",new Error)}}var sn=["<nothing>"],un="end",on="value",an="error",hn="any";i(v.prototype,{add:function(t,n){return this._items=r(this._items,[{type:t,fn:n}]),this._items.length},remove:function(t,n){var i=u(this._items,function(i){return i.type===t&&i.fn===n});return 0!==this._inLoop&&-1!==i&&(null===this._removedItems&&(this._removedItems=[]),this._removedItems.push(this._items[i])),this._items=a(this._items,i),this._items.length},addSpy:function(t){return this._spies=r(this._spies,[t]),this._spies.length},removeSpy:function(t){return this._spies=a(this._spies,this._spies.indexOf(t)),this._spies.length},dispatch:function(t){this._inLoop++;for(var n=0,i=this._spies;null!==this._spies&&n<i.length;n++)i[n](t);for(var e=0,r=this._items;e<r.length&&null!==this._items;e++)null!==this._removedItems&&f(this._removedItems,r[e])||d(r[e].type,r[e].fn,t);0===--this._inLoop&&(this._removedItems=null)},cleanup:function(){this._items=null,this._spies=null}}),i(p.prototype,{_name:"observable",_onActivation:function(){},_onDeactivation:function(){},_setActive:function(t){this._active!==t&&(this._active=t,t?(this._activating=!0,this._onActivation(),this._activating=!1):this._onDeactivation())},_clear:function(){this._setActive(!1),this._dispatcher.cleanup(),this._dispatcher=null,this._logHandlers=null},_emit:function(t,n){switch(t){case on:return this._emitValue(n);case an:return this._emitError(n);case un:return this._emitEnd()}},_emitValue:function(t){this._alive&&this._dispatcher.dispatch({type:on,value:t})},_emitError:function(t){this._alive&&this._dispatcher.dispatch({type:an,value:t})},_emitEnd:function(){this._alive&&(this._alive=!1,this._dispatcher.dispatch({type:un}),this._clear())},_on:function(t,n){return this._alive?(this._dispatcher.add(t,n),this._setActive(!0)):d(t,n,{type:un}),this},_off:function(t,n){if(this._alive){0===this._dispatcher.remove(t,n)&&this._setActive(!1)}return this},onValue:function(t){return this._on(on,t)},onError:function(t){return this._on(an,t)},onEnd:function(t){return this._on(un,t)},onAny:function(t){return this._on(hn,t)},offValue:function(t){return this._off(on,t)},offError:function(t){return this._off(an,t)},offEnd:function(t){return this._off(un,t)},offAny:function(t){return this._off(hn,t)},observe:function(t,n,i){var e=this,r=!1,s=t&&"function"!=typeof t?t:{value:t,error:n,end:i},u=function(t){t.type===un&&(r=!0),t.type===on&&s.value?s.value(t.value):t.type===an&&s.error?s.error(t.value):t.type===un&&s.end&&s.end(t.value)};return this.onAny(u),{unsubscribe:function(){r||(e.offAny(u),r=!0)},get closed(){return r}}},_ofSameType:function(t,n){return t.prototype.getType()===this.getType()?t:n},setName:function(t,n){return this._name=n?t._name+"."+n:t,this},log:function(){var t=arguments.length>0&&void 0!==arguments[0]?arguments[0]:this.toString(),n=void 0,i=function(i){var e="<"+i.type+(n?":current":"")+">";i.type===un?console.log(t,e):console.log(t,e,i.value)};return this._alive&&(this._logHandlers||(this._logHandlers=[]),this._logHandlers.push({name:t,handler:i})),n=!0,this.onAny(i),n=!1,this},offLog:function(){var t=arguments.length>0&&void 0!==arguments[0]?arguments[0]:this.toString();if(this._logHandlers){var n=u(this._logHandlers,function(n){return n.name===t});-1!==n&&(this.offAny(this._logHandlers[n].handler),this._logHandlers.splice(n,1))}return this},spy:function(){var t=arguments.length>0&&void 0!==arguments[0]?arguments[0]:this.toString(),n=function(n){var i="<"+n.type+">";n.type===un?console.log(t,i):console.log(t,i,n.value)};return this._alive&&(this._spyHandlers||(this._spyHandlers=[]),this._spyHandlers.push({name:t,handler:n}),this._dispatcher.addSpy(n)),this},offSpy:function(){var t=arguments.length>0&&void 0!==arguments[0]?arguments[0]:this.toString();if(this._spyHandlers){var n=u(this._spyHandlers,function(n){return n.name===t});-1!==n&&(this._dispatcher.removeSpy(this._spyHandlers[n].handler),this._spyHandlers.splice(n,1))}return this}}),p.prototype.toString=function(){return"["+this._name+"]"},e(m,p,{_name:"stream",getType:function(){return"stream"}}),e(y,p,{_name:"property",_emitValue:function(t){this._alive&&(this._currentEvent={type:on,value:t},this._activating||this._dispatcher.dispatch({type:on,value:t}))},_emitError:function(t){this._alive&&(this._currentEvent={type:an,value:t},this._activating||this._dispatcher.dispatch({type:an,value:t}))},_emitEnd:function(){this._alive&&(this._alive=!1,this._activating||this._dispatcher.dispatch({type:un}),this._clear())},_on:function(t,n){return this._alive&&(this._dispatcher.add(t,n),this._setActive(!0)),null!==this._currentEvent&&d(t,n,this._currentEvent),this._alive||d(t,n,{type:un}),this},getType:function(){return"property"}});var ln=new m;ln._emitEnd(),ln._name="never";var _n=E({_name:"later",_init:function(t){var n=t.x;this._x=n},_free:function(){this._x=null},_onTick:function(){this._emitValue(this._x),this._emitEnd()}}),fn=E({_name:"interval",_init:function(t){var n=t.x;this._x=n},_free:function(){this._x=null},_onTick:function(){this._emitValue(this._x)}}),cn=E({_name:"sequentially",_init:function(t){var n=t.xs;this._xs=o(n)},_free:function(){this._xs=null},_onTick:function(){1===this._xs.length?(this._emitValue(this._xs[0]),this._emitEnd()):this._emitValue(this._xs.shift())}}),dn=E({_name:"fromPoll",_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_onTick:function(){var t=this._fn;this._emitValue(t())}}),vn=E({_name:"withInterval",_init:function(t){var n=t.fn;this._fn=n,this._emitter=V(this)},_free:function(){this._fn=null,this._emitter=null},_onTick:function(){(0,this._fn)(this._emitter)}});e($,m,{_name:"stream",_onActivation:function(){var t=this._fn,n=t(V(this));this._unsubscribe="function"==typeof n?n:null,this._active||this._callUnsubscribe()},_callUnsubscribe:function(){null!==this._unsubscribe&&(this._unsubscribe(),this._unsubscribe=null)},_onDeactivation:function(){this._callUnsubscribe()},_clear:function(){m.prototype._clear.call(this),this._fn=null}});var pn=[["addEventListener","removeEventListener"],["addListener","removeListener"],["on","off"]];e(H,y,{_name:"constant",_active:!1,_activating:!1,_alive:!1,_dispatcher:null,_logHandlers:null}),e(D,y,{_name:"constantError",_active:!1,_activating:!1,_alive:!1,_dispatcher:null,_logHandlers:null});var mn=j("toProperty",{_init:function(t){var n=t.fn;this._getInitialCurrent=n},_onActivation:function(){if(null!==this._getInitialCurrent){var t=this._getInitialCurrent;this._emitValue(t())}this._source.onAny(this._$handleAny)}}),yn=B("changes",{_handleValue:function(t){this._activating||this._emitValue(t)},_handleError:function(t){this._activating||this._emitError(t)}}),gn=function(t){var n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:z(),i=null;return new n(function(n,e){t.onAny(function(t){t.type===un&&null!==i?((i.type===on?n:e)(i.value),i=null):i=t})})},En="undefined"!=typeof window?window:"undefined"!=typeof global?global:"undefined"!=typeof self?self:{},bn=Y(function(t,n){function i(t){var n,i=t.Symbol;return"function"==typeof i?i.observable?n=i.observable:(n=i("observable"),i.observable=n):n="@@observable",n}Object.defineProperty(n,"__esModule",{value:!0}),n.default=i}),An=Y(function(t,n){Object.defineProperty(n,"__esModule",{value:!0});var i,e=function(t){return t&&t.__esModule?t:{default:t}}(bn);i="undefined"!=typeof self?self:"undefined"!=typeof window?window:void 0!==En?En:t;var r=(0,e.default)(i);n.default=r}),wn=An,Sn=wn.default?wn.default:wn;i(G.prototype,{subscribe:function(t,n,i){var e=this,r="function"==typeof t?{next:t,error:n,complete:i}:t,s=function(t){t.type===un&&(u=!0),t.type===on&&r.next?r.next(t.value):t.type===an&&r.error?r.error(t.value):t.type===un&&r.complete&&r.complete(t.value)};this._observable.onAny(s);var u=!1;return{unsubscribe:function(){u=!0,e._observable.offAny(s)},get closed(){return u}}}}),G.prototype[Sn]=function(){return this},e(Z,m,{_name:"combine",_onActivation:function(){this._aliveCount=this._activeCount;for(var t=this._activeCount;t<this._sources.length;t++)this._sources[t].onAny(this._$handlers[t]);for(var n=0;n<this._activeCount;n++)this._sources[n].onAny(this._$handlers[n]);this._emitAfterActivation&&(this._emitAfterActivation=!1,this._emitIfFull()),this._endAfterActivation&&this._emitEnd()},_onDeactivation:function(){var t=this._sources.length,n=void 0;for(n=0;n<t;n++)this._sources[n].offAny(this._$handlers[n])},_emitIfFull:function(){for(var t=!0,n=!1,i=this._latestValues.length,e=new Array(i),r=new Array(i),s=0;s<i;s++)e[s]=this._latestValues[s],r[s]=this._latestErrors[s],e[s]===sn&&(t=!1),void 0!==r[s]&&(n=!0);if(t){var u=this._combinator;this._emitValue(u(e))}n&&this._emitError(X(r))},_handleAny:function(t,n){n.type===on||n.type===an?(n.type===on&&(this._latestValues[t]=n.value,this._latestErrors[t]=void 0),n.type===an&&(this._latestValues[t]=sn,this._latestErrors[t]={index:this._latestErrorIndex++,error:n.value}),t<this._activeCount&&(this._activating?this._emitAfterActivation=!0:this._emitIfFull())):t<this._activeCount&&0===--this._aliveCount&&(this._activating?this._endAfterActivation=!0:this._emitEnd())},_clear:function(){m.prototype._clear.call(this),this._sources=null,this._latestValues=null,this._latestErrors=null,this._combinator=null,this._$handlers=null}});var Vn={empty:function(){return g()},concat:function(t,n){return t.merge(n)},of:function(t){return M(t)},map:function(t,n){return n.map(t)},bimap:function(t,n,i){return i.mapErrors(t).map(n)},ap:function(t,n){return it([t,n],function(t,n){return t(n)})},chain:function(t,n){return n.flatMap(t)}},Tn=Object.freeze({Observable:Vn}),$n={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleValue:function(t){var n=this._fn;this._emitValue(n(t))}},Cn=B("map",$n),kn=j("map",$n),On=function(t){return t},In={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleValue:function(t){(0,this._fn)(t)&&this._emitValue(t)}},xn=B("filter",In),Ln=j("filter",In),Pn=function(t){return t},Hn={_init:function(t){var n=t.n;this._n=n,n<=0&&this._emitEnd()},_handleValue:function(t){0!==this._n&&(this._n--,this._emitValue(t),0===this._n&&this._emitEnd())}},Mn=B("take",Hn),Dn=j("take",Hn),Nn={_init:function(t){var n=t.n;this._n=n,n<=0&&this._emitEnd()},_handleError:function(t){0!==this._n&&(this._n--,this._emitError(t),0===this._n&&this._emitEnd())}},qn=B("takeErrors",Nn),Wn=j("takeErrors",Nn),Bn={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleValue:function(t){(0,this._fn)(t)?this._emitValue(t):this._emitEnd()}},jn=B("takeWhile",Bn),Un=j("takeWhile",Bn),Fn=function(t){return t},Qn={_init:function(){this._lastValue=sn},_free:function(){this._lastValue=null},_handleValue:function(t){this._lastValue=t},_handleEnd:function(){this._lastValue!==sn&&this._emitValue(this._lastValue),this._emitEnd()}},zn=B("last",Qn),Yn=j("last",Qn),Kn={_init:function(t){var n=t.n;this._n=Math.max(0,n)},_handleValue:function(t){0===this._n?this._emitValue(t):this._n--}},Gn=B("skip",Kn),Jn=j("skip",Kn),Rn={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleValue:function(t){var n=this._fn;null===this._fn||n(t)||(this._fn=null),null===this._fn&&this._emitValue(t)}},Xn=B("skipWhile",Rn),Zn=j("skipWhile",Rn),ti=function(t){return t},ni={_init:function(t){var n=t.fn;this._fn=n,this._prev=sn},_free:function(){this._fn=null,this._prev=null},_handleValue:function(t){var n=this._fn;this._prev!==sn&&n(this._prev,t)||(this._prev=t,this._emitValue(t))}},ii=B("skipDuplicates",ni),ei=j("skipDuplicates",ni),ri=function(t,n){return t===n},si={_init:function(t){var n=t.fn,i=t.seed;this._fn=n,this._prev=i},_free:function(){this._prev=null,this._fn=null},_handleValue:function(t){if(this._prev!==sn){var n=this._fn;this._emitValue(n(this._prev,t))}this._prev=t}},ui=B("diff",si),oi=j("diff",si),ai=j("scan",{_init:function(t){var n=t.fn,i=t.seed;this._fn=n,this._seed=i,i!==sn&&this._emitValue(i)},_free:function(){this._fn=null,this._seed=null},_handleValue:function(t){var n=this._fn;null===this._currentEvent||this._currentEvent.type===an?this._emitValue(this._seed===sn?t:n(this._seed,t)):this._emitValue(n(this._currentEvent.value,t))}}),hi={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleValue:function(t){for(var n=this._fn,i=n(t),e=0;e<i.length;e++)this._emitValue(i[e])}},li=B("flatten",hi),_i=function(t){return t},fi={},ci={_init:function(t){var n=this,i=t.wait;this._wait=Math.max(0,i),this._buff=[],this._$shiftBuff=function(){var t=n._buff.shift();t===fi?n._emitEnd():n._emitValue(t)}},_free:function(){this._buff=null,this._$shiftBuff=null},_handleValue:function(t){this._activating?this._emitValue(t):(this._buff.push(t),setTimeout(this._$shiftBuff,this._wait))},_handleEnd:function(){this._activating?this._emitEnd():(this._buff.push(fi),setTimeout(this._$shiftBuff,this._wait))}},di=B("delay",ci),vi=j("delay",ci),pi=Date.now?function(){return Date.now()}:function(){return(new Date).getTime()},mi={_init:function(t){var n=this,i=t.wait,e=t.leading,r=t.trailing;this._wait=Math.max(0,i),this._leading=e,this._trailing=r,this._trailingValue=null,this._timeoutId=null,this._endLater=!1,this._lastCallTime=0,this._$trailingCall=function(){return n._trailingCall()}},_free:function(){this._trailingValue=null,this._$trailingCall=null},_handleValue:function(t){if(this._activating)this._emitValue(t);else{var n=pi();0!==this._lastCallTime||this._leading||(this._lastCallTime=n);var i=this._wait-(n-this._lastCallTime);i<=0?(this._cancelTrailing(),this._lastCallTime=n,this._emitValue(t)):this._trailing&&(this._cancelTrailing(),this._trailingValue=t,this._timeoutId=setTimeout(this._$trailingCall,i))}},_handleEnd:function(){this._activating?this._emitEnd():this._timeoutId?this._endLater=!0:this._emitEnd()},_cancelTrailing:function(){null!==this._timeoutId&&(clearTimeout(this._timeoutId),this._timeoutId=null)},_trailingCall:function(){this._emitValue(this._trailingValue),this._timeoutId=null,this._trailingValue=null,this._lastCallTime=this._leading?pi():0,this._endLater&&this._emitEnd()}},yi=B("throttle",mi),gi=j("throttle",mi),Ei={_init:function(t){var n=this,i=t.wait,e=t.immediate;this._wait=Math.max(0,i),this._immediate=e,this._lastAttempt=0,this._timeoutId=null,this._laterValue=null,this._endLater=!1,this._$later=function(){return n._later()}},_free:function(){this._laterValue=null,this._$later=null},_handleValue:function(t){this._activating?this._emitValue(t):(this._lastAttempt=pi(),this._immediate&&!this._timeoutId&&this._emitValue(t),this._timeoutId||(this._timeoutId=setTimeout(this._$later,this._wait)),this._immediate||(this._laterValue=t))},_handleEnd:function(){this._activating?this._emitEnd():this._timeoutId&&!this._immediate?this._endLater=!0:this._emitEnd()},_later:function(){var t=pi()-this._lastAttempt;t<this._wait&&t>=0?this._timeoutId=setTimeout(this._$later,this._wait-t):(this._timeoutId=null,this._immediate||(this._emitValue(this._laterValue),this._laterValue=null),this._endLater&&this._emitEnd())}},bi=B("debounce",Ei),Ai=j("debounce",Ei),wi={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleError:function(t){var n=this._fn;this._emitError(n(t))}},Si=B("mapErrors",wi),Vi=j("mapErrors",wi),Ti=function(t){return t},$i={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleError:function(t){(0,this._fn)(t)&&this._emitError(t)}},Ci=B("filterErrors",$i),ki=j("filterErrors",$i),Oi=function(t){return t},Ii={_handleValue:function(){}},xi=B("ignoreValues",Ii),Li=j("ignoreValues",Ii),Pi={_handleError:function(){}},Hi=B("ignoreErrors",Pi),Mi=j("ignoreErrors",Pi),Di={_handleEnd:function(){}},Ni=B("ignoreEnd",Di),qi=j("ignoreEnd",Di),Wi={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleEnd:function(){var t=this._fn;this._emitValue(t()),this._emitEnd()}},Bi=B("beforeEnd",Wi),ji=j("beforeEnd",Wi),Ui={_init:function(t){var n=t.min,i=t.max;this._max=i,this._min=n,this._buff=[]},_free:function(){this._buff=null},_handleValue:function(t){this._buff=c(this._buff,t,this._max),this._buff.length>=this._min&&this._emitValue(this._buff)}},Fi=B("slidingWindow",Ui),Qi=j("slidingWindow",Ui),zi={_init:function(t){var n=t.fn,i=t.flushOnEnd;this._fn=n,this._flushOnEnd=i,this._buff=[]},_free:function(){this._buff=null},_flush:function(){null!==this._buff&&0!==this._buff.length&&(this._emitValue(this._buff),this._buff=[])},_handleValue:function(t){this._buff.push(t),(0,this._fn)(t)||this._flush()},_handleEnd:function(){this._flushOnEnd&&this._flush(),this._emitEnd()}},Yi=B("bufferWhile",zi),Ki=j("bufferWhile",zi),Gi=function(t){return t},Ji={_init:function(t){var n=t.count,i=t.flushOnEnd;this._count=n,this._flushOnEnd=i,this._buff=[]},_free:function(){this._buff=null},_flush:function(){ | ||
| null!==this._buff&&0!==this._buff.length&&(this._emitValue(this._buff),this._buff=[])},_handleValue:function(t){this._buff.push(t),this._buff.length>=this._count&&this._flush()},_handleEnd:function(){this._flushOnEnd&&this._flush(),this._emitEnd()}},Ri=B("bufferWithCount",Ji),Xi=j("bufferWithCount",Ji),Zi={_init:function(t){var n=this,i=t.wait,e=t.count,r=t.flushOnEnd;this._wait=i,this._count=e,this._flushOnEnd=r,this._intervalId=null,this._$onTick=function(){return n._flush()},this._buff=[]},_free:function(){this._$onTick=null,this._buff=null},_flush:function(){null!==this._buff&&(this._emitValue(this._buff),this._buff=[])},_handleValue:function(t){this._buff.push(t),this._buff.length>=this._count&&(clearInterval(this._intervalId),this._flush(),this._intervalId=setInterval(this._$onTick,this._wait))},_handleEnd:function(){this._flushOnEnd&&0!==this._buff.length&&this._flush(),this._emitEnd()},_onActivation:function(){this._intervalId=setInterval(this._$onTick,this._wait),this._source.onAny(this._$handleAny)},_onDeactivation:function(){null!==this._intervalId&&(clearInterval(this._intervalId),this._intervalId=null),this._source.offAny(this._$handleAny)}},te=B("bufferWithTimeOrCount",Zi),ne=j("bufferWithTimeOrCount",Zi),ie={_init:function(t){var n=t.transducer;this._xform=n(kt(this))},_free:function(){this._xform=null},_handleValue:function(t){null!==this._xform["@@transducer/step"](null,t)&&this._xform["@@transducer/result"](null)},_handleEnd:function(){this._xform["@@transducer/result"](null)}},ee=B("transduce",ie),re=j("transduce",ie),se={_init:function(t){var n=t.fn;this._handler=n,this._emitter=V(this)},_free:function(){this._handler=null,this._emitter=null},_handleAny:function(t){this._handler(this._emitter,t)}},ue=B("withHandler",se),oe=j("withHandler",se),ae=Array.isArray||function(t){return"[object Array]"===Object.prototype.toString.call(t)};e(xt,m,{_name:"zip",_onActivation:function(){for(;this._isFull();)this._emit();var t=this._sources.length;this._aliveCount=t;for(var n=0;n<t&&this._active;n++)this._sources[n].onAny(this._$handlers[n])},_onDeactivation:function(){for(var t=0;t<this._sources.length;t++)this._sources[t].offAny(this._$handlers[t])},_emit:function(){for(var t=new Array(this._buffers.length),n=0;n<this._buffers.length;n++)t[n]=this._buffers[n].shift();var i=this._combinator;this._emitValue(i(t))},_isFull:function(){for(var t=0;t<this._buffers.length;t++)if(0===this._buffers[t].length)return!1;return!0},_handleAny:function(t,n){n.type===on&&(this._buffers[t].push(n.value),this._isFull()&&this._emit()),n.type===an&&this._emitError(n.value),n.type===un&&0===--this._aliveCount&&this._emitEnd()},_clear:function(){m.prototype._clear.call(this),this._sources=null,this._buffers=null,this._combinator=null,this._$handlers=null}});var he=function(t){return t};e(Pt,m,{_name:"abstractPool",_add:function(t,n){n=n||he,-1===this._concurLim||this._curSources.length<this._concurLim?this._addToCur(n(t)):-1===this._queueLim||this._queue.length<this._queueLim?this._addToQueue(n(t)):"old"===this._drop&&(this._removeOldest(),this._add(t,n))},_addAll:function(t){var n=this;l(t,function(t){return n._add(t)})},_remove:function(t){-1===this._removeCur(t)&&this._removeQueue(t)},_addToQueue:function(t){this._queue=r(this._queue,[t])},_addToCur:function(t){if(this._active){if(!t._alive)return void(t._currentEvent&&this._emit(t._currentEvent.type,t._currentEvent.value));this._currentlyAdding=t,t.onAny(this._$handleSubAny),this._currentlyAdding=null,t._alive&&(this._curSources=r(this._curSources,[t]),this._active&&this._subToEnd(t))}else this._curSources=r(this._curSources,[t])},_subToEnd:function(t){var n=this,i=function(){return n._removeCur(t)};this._$endHandlers.push({obs:t,handler:i}),t.onEnd(i)},_subscribe:function(t){t.onAny(this._$handleSubAny),this._active&&this._subToEnd(t)},_unsubscribe:function(t){t.offAny(this._$handleSubAny);var n=u(this._$endHandlers,function(n){return n.obs===t});-1!==n&&(t.offEnd(this._$endHandlers[n].handler),this._$endHandlers.splice(n,1))},_handleSubAny:function(t){t.type===on?this._emitValue(t.value):t.type===an&&this._emitError(t.value)},_removeQueue:function(t){var n=s(this._queue,t);return this._queue=a(this._queue,n),n},_removeCur:function(t){this._active&&this._unsubscribe(t);var n=s(this._curSources,t);return this._curSources=a(this._curSources,n),-1!==n&&(0!==this._queue.length?this._pullQueue():0===this._curSources.length&&this._onEmpty()),n},_removeOldest:function(){this._removeCur(this._curSources[0])},_pullQueue:function(){0!==this._queue.length&&(this._queue=o(this._queue),this._addToCur(this._queue.shift()))},_onActivation:function(){for(var t=0,n=this._curSources;t<n.length&&this._active;t++)this._subscribe(n[t])},_onDeactivation:function(){for(var t=0,n=this._curSources;t<n.length;t++)this._unsubscribe(n[t]);null!==this._currentlyAdding&&this._unsubscribe(this._currentlyAdding)},_isEmpty:function(){return 0===this._curSources.length},_onEmpty:function(){},_clear:function(){m.prototype._clear.call(this),this._queue=null,this._curSources=null,this._$handleSubAny=null,this._$endHandlers=null}}),e(Ht,Pt,{_name:"merge",_onEmpty:function(){this._initialised&&this._emitEnd()}}),e(Dt,m,{_name:"repeat",_handleAny:function(t){t.type===un?(this._source=null,this._getSource()):this._emit(t.type,t.value)},_getSource:function(){if(!this._inLoop){this._inLoop=!0;for(var t=this._generator;null===this._source&&this._alive&&this._active;)this._source=t(this._iteration++),this._source?this._source.onAny(this._$handleAny):this._emitEnd();this._inLoop=!1}},_onActivation:function(){this._source?this._source.onAny(this._$handleAny):this._getSource()},_onDeactivation:function(){this._source&&this._source.offAny(this._$handleAny)},_clear:function(){m.prototype._clear.call(this),this._generator=null,this._source=null,this._$handleAny=null}});var le=function(t){return new Dt(t)};e(qt,Pt,{_name:"pool",plug:function(t){return this._add(t),this},unplug:function(t){return this._remove(t),this}}),e(Wt,Pt,{_onActivation:function(){Pt.prototype._onActivation.call(this),this._active&&this._source.onAny(this._$handleMain)},_onDeactivation:function(){Pt.prototype._onDeactivation.call(this),this._source.offAny(this._$handleMain),this._hadNoEvSinceDeact=!0},_handleMain:function(t){if(t.type===on){this._activating&&this._hadNoEvSinceDeact&&this._lastCurrent===t.value||this._add(t.value,this._fn),this._lastCurrent=t.value,this._hadNoEvSinceDeact=!1}t.type===an&&this._emitError(t.value),t.type===un&&(this._isEmpty()?this._emitEnd():this._mainEnded=!0)},_onEmpty:function(){this._mainEnded&&this._emitEnd()},_clear:function(){Pt.prototype._clear.call(this),this._source=null,this._lastCurrent=null,this._$handleMain=null}}),e(Bt,Wt,{_handleMain:function(t){if(t.type===an){this._activating&&this._hadNoEvSinceDeact&&this._lastCurrent===t.value||this._add(t.value,this._fn),this._lastCurrent=t.value,this._hadNoEvSinceDeact=!1}t.type===on&&this._emitValue(t.value),t.type===un&&(this._isEmpty()?this._emitEnd():this._mainEnded=!0)}});var _e={_handlePrimaryValue:function(t){this._lastSecondary!==sn&&this._lastSecondary&&this._emitValue(t)},_handleSecondaryEnd:function(){this._lastSecondary!==sn&&this._lastSecondary||this._emitEnd()}},fe=Ft("filterBy",_e),ce=Qt("filterBy",_e),de=function(t,n){return n},ve={_handlePrimaryValue:function(t){this._lastSecondary!==sn&&this._emitValue(t)},_handleSecondaryEnd:function(){this._lastSecondary===sn&&this._emitEnd()}},pe=Ft("skipUntilBy",ve),me=Qt("skipUntilBy",ve),ye={_handleSecondaryValue:function(){this._emitEnd()}},ge=Ft("takeUntilBy",ye),Ee=Qt("takeUntilBy",ye),be={_init:function(){var t=arguments.length>0&&void 0!==arguments[0]?arguments[0]:{},n=t.flushOnEnd,i=void 0===n||n;this._buff=[],this._flushOnEnd=i},_free:function(){this._buff=null},_flush:function(){null!==this._buff&&(this._emitValue(this._buff),this._buff=[])},_handlePrimaryEnd:function(){this._flushOnEnd&&this._flush(),this._emitEnd()},_onActivation:function(){this._primary.onAny(this._$handlePrimaryAny),this._alive&&null!==this._secondary&&this._secondary.onAny(this._$handleSecondaryAny)},_handlePrimaryValue:function(t){this._buff.push(t)},_handleSecondaryValue:function(){this._flush()},_handleSecondaryEnd:function(){this._flushOnEnd||this._emitEnd()}},Ae=Ft("bufferBy",be),we=Qt("bufferBy",be),Se={_init:function(){var t=arguments.length>0&&void 0!==arguments[0]?arguments[0]:{},n=t.flushOnEnd,i=void 0===n||n,e=t.flushOnChange,r=void 0!==e&&e;this._buff=[],this._flushOnEnd=i,this._flushOnChange=r},_free:function(){this._buff=null},_flush:function(){null!==this._buff&&(this._emitValue(this._buff),this._buff=[])},_handlePrimaryEnd:function(){this._flushOnEnd&&this._flush(),this._emitEnd()},_handlePrimaryValue:function(t){this._buff.push(t),this._lastSecondary===sn||this._lastSecondary||this._flush()},_handleSecondaryEnd:function(){this._flushOnEnd||this._lastSecondary!==sn&&!this._lastSecondary||this._emitEnd()},_handleSecondaryValue:function(t){this._flushOnChange&&!t&&this._flush(),this._lastSecondary=t}},Ve=Ft("bufferWhileBy",Se),Te=Qt("bufferWhileBy",Se),$e=function(){return!1},Ce=function(){return!0},ke={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleValue:function(t){var n=this._fn,i=n(t);i.convert?this._emitError(i.error):this._emitValue(t)}},Oe=B("valuesToErrors",ke),Ie=j("valuesToErrors",ke),xe=function(t){return{convert:!0,error:t}},Le={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleError:function(t){var n=this._fn,i=n(t);i.convert?this._emitValue(i.value):this._emitError(t)}},Pe=B("errorsToValues",Le),He=j("errorsToValues",Le),Me=function(t){return{convert:!0,value:t}},De={_handleError:function(t){this._emitError(t),this._emitEnd()}},Ne=B("endOnError",De),qe=j("endOnError",De);p.prototype.toProperty=function(t){return U(this,t)},p.prototype.changes=function(){return F(this)},p.prototype.toPromise=function(t){return gn(this,t)},p.prototype.toESObservable=J,p.prototype[Sn]=J,p.prototype.map=function(t){return et(this,t)},p.prototype.filter=function(t){return rt(this,t)},p.prototype.take=function(t){return st(this,t)},p.prototype.takeErrors=function(t){return ut(this,t)},p.prototype.takeWhile=function(t){return ot(this,t)},p.prototype.last=function(){return at(this)},p.prototype.skip=function(t){return ht(this,t)},p.prototype.skipWhile=function(t){return lt(this,t)},p.prototype.skipDuplicates=function(t){return _t(this,t)},p.prototype.diff=function(t,n){return ct(this,t,n)},p.prototype.scan=function(t,n){return dt(this,t,n)},p.prototype.flatten=function(t){return vt(this,t)},p.prototype.delay=function(t){return pt(this,t)},p.prototype.throttle=function(t,n){return mt(this,t,n)},p.prototype.debounce=function(t,n){return yt(this,t,n)},p.prototype.mapErrors=function(t){return gt(this,t)},p.prototype.filterErrors=function(t){return Et(this,t)},p.prototype.ignoreValues=function(){return bt(this)},p.prototype.ignoreErrors=function(){return At(this)},p.prototype.ignoreEnd=function(){return wt(this)},p.prototype.beforeEnd=function(t){return St(this,t)},p.prototype.slidingWindow=function(t,n){return Vt(this,t,n)},p.prototype.bufferWhile=function(t,n){return Tt(this,t,n)},p.prototype.bufferWithCount=function(t,n){return $t(this,t,n)},p.prototype.bufferWithTimeOrCount=function(t,n,i){return Ct(this,t,n,i)},p.prototype.transduce=function(t){return Ot(this,t)},p.prototype.withHandler=function(t){return It(this,t)},p.prototype.thru=function(t){return t(this)},p.prototype.combine=function(t,n){return it([this,t],n)},p.prototype.zip=function(t,n){return Lt([this,t],n)},p.prototype.merge=function(t){return Mt([this,t])},p.prototype.concat=function(t){return Nt([this,t])};var We=function(){return new qt};p.prototype.flatMap=function(t){return new Wt(this,t).setName(this,"flatMap")},p.prototype.flatMapLatest=function(t){return new Wt(this,t,{concurLim:1,drop:"old"}).setName(this,"flatMapLatest")},p.prototype.flatMapFirst=function(t){return new Wt(this,t,{concurLim:1}).setName(this,"flatMapFirst")},p.prototype.flatMapConcat=function(t){return new Wt(this,t,{queueLim:-1,concurLim:1}).setName(this,"flatMapConcat")},p.prototype.flatMapConcurLimit=function(t,n){return new Wt(this,t,{queueLim:-1,concurLim:n}).setName(this,"flatMapConcurLimit")},p.prototype.flatMapErrors=function(t){return new Bt(this,t).setName(this,"flatMapErrors")},p.prototype.filterBy=function(t){return zt(this,t)},p.prototype.sampledBy=function(t,n){return Yt(this,t,n)},p.prototype.skipUntilBy=function(t){return Kt(this,t)},p.prototype.takeUntilBy=function(t){return Gt(this,t)},p.prototype.bufferBy=function(t,n){return Jt(this,t,n)},p.prototype.bufferWhileBy=function(t,n){return Rt(this,t,n)};var Be=!0;p.prototype.awaiting=function(t){return rn("You are using deprecated .awaiting() method, see https://github.com/rpominov/kefir/issues/145"),Xt(this,t)},p.prototype.valuesToErrors=function(t){return rn("You are using deprecated .valuesToErrors() method, see https://github.com/rpominov/kefir/issues/149"),Zt(this,t)},p.prototype.errorsToValues=function(t){return rn("You are using deprecated .errorsToValues() method, see https://github.com/rpominov/kefir/issues/149"),tn(this,t)},p.prototype.endOnError=function(){return rn("You are using deprecated .endOnError() method, see https://github.com/rpominov/kefir/issues/150"),nn(this)};var je={Observable:p,Stream:m,Property:y,never:g,later:b,interval:A,sequentially:w,fromPoll:S,withInterval:T,fromCallback:k,fromNodeCallback:O,fromEvents:P,stream:C,constant:M,constantError:N,fromPromise:Q,fromESObservable:K,combine:it,zip:Lt,merge:Mt,concat:Nt,Pool:qt,pool:We,repeat:le,staticLand:Tn};je.Kefir=je,t.dissableDeprecationWarnings=en,t.Kefir=je,t.Observable=p,t.Stream=m,t.Property=y,t.never=g,t.later=b,t.interval=A,t.sequentially=w,t.fromPoll=S,t.withInterval=T,t.fromCallback=k,t.fromNodeCallback=O,t.fromEvents=P,t.stream=C,t.constant=M,t.constantError=N,t.fromPromise=Q,t.fromESObservable=K,t.combine=it,t.zip=Lt,t.merge=Mt,t.concat=Nt,t.Pool=qt,t.pool=We,t.repeat=le,t.staticLand=Tn,t.default=je,Object.defineProperty(t,"__esModule",{value:!0})}); | ||
| null!==this._buff&&0!==this._buff.length&&(this._emitValue(this._buff),this._buff=[])},_handleValue:function(t){this._buff.push(t),this._buff.length>=this._count&&this._flush()},_handleEnd:function(){this._flushOnEnd&&this._flush(),this._emitEnd()}},Ri=B("bufferWithCount",Ji),Xi=j("bufferWithCount",Ji),Zi={_init:function(t){var n=this,i=t.wait,e=t.count,r=t.flushOnEnd;this._wait=i,this._count=e,this._flushOnEnd=r,this._intervalId=null,this._$onTick=function(){return n._flush()},this._buff=[]},_free:function(){this._$onTick=null,this._buff=null},_flush:function(){null!==this._buff&&(this._emitValue(this._buff),this._buff=[])},_handleValue:function(t){this._buff.push(t),this._buff.length>=this._count&&(clearInterval(this._intervalId),this._flush(),this._intervalId=setInterval(this._$onTick,this._wait))},_handleEnd:function(){this._flushOnEnd&&0!==this._buff.length&&this._flush(),this._emitEnd()},_onActivation:function(){this._intervalId=setInterval(this._$onTick,this._wait),this._source.onAny(this._$handleAny)},_onDeactivation:function(){null!==this._intervalId&&(clearInterval(this._intervalId),this._intervalId=null),this._source.offAny(this._$handleAny)}},te=B("bufferWithTimeOrCount",Zi),ne=j("bufferWithTimeOrCount",Zi),ie={_init:function(t){var n=t.transducer;this._xform=n(kt(this))},_free:function(){this._xform=null},_handleValue:function(t){null!==this._xform["@@transducer/step"](null,t)&&this._xform["@@transducer/result"](null)},_handleEnd:function(){this._xform["@@transducer/result"](null)}},ee=B("transduce",ie),re=j("transduce",ie),se={_init:function(t){var n=t.fn;this._handler=n,this._emitter=V(this)},_free:function(){this._handler=null,this._emitter=null},_handleAny:function(t){this._handler(this._emitter,t)}},ue=B("withHandler",se),oe=j("withHandler",se),ae=Array.isArray||function(t){return"[object Array]"===Object.prototype.toString.call(t)};e(xt,m,{_name:"zip",_onActivation:function(){for(;this._isFull();)this._emit();var t=this._sources.length;this._aliveCount=t;for(var n=0;n<t&&this._active;n++)this._sources[n].onAny(this._$handlers[n])},_onDeactivation:function(){for(var t=0;t<this._sources.length;t++)this._sources[t].offAny(this._$handlers[t])},_emit:function(){for(var t=new Array(this._buffers.length),n=0;n<this._buffers.length;n++)t[n]=this._buffers[n].shift();var i=this._combinator;this._emitValue(i(t))},_isFull:function(){for(var t=0;t<this._buffers.length;t++)if(0===this._buffers[t].length)return!1;return!0},_handleAny:function(t,n){n.type===on&&(this._buffers[t].push(n.value),this._isFull()&&this._emit()),n.type===an&&this._emitError(n.value),n.type===un&&0===--this._aliveCount&&this._emitEnd()},_clear:function(){m.prototype._clear.call(this),this._sources=null,this._buffers=null,this._combinator=null,this._$handlers=null}});var he=function(t){return t};e(Pt,m,{_name:"abstractPool",_add:function(t,n){n=n||he,-1===this._concurLim||this._curSources.length<this._concurLim?this._addToCur(n(t)):-1===this._queueLim||this._queue.length<this._queueLim?this._addToQueue(n(t)):"old"===this._drop&&(this._removeOldest(),this._add(t,n))},_addAll:function(t){var n=this;l(t,function(t){return n._add(t)})},_remove:function(t){-1===this._removeCur(t)&&this._removeQueue(t)},_addToQueue:function(t){this._queue=r(this._queue,[t])},_addToCur:function(t){if(this._active){if(!t._alive)return void(t._currentEvent&&this._emit(t._currentEvent.type,t._currentEvent.value));this._currentlyAdding=t,t.onAny(this._$handleSubAny),this._currentlyAdding=null,t._alive&&(this._curSources=r(this._curSources,[t]),this._active&&this._subToEnd(t))}else this._curSources=r(this._curSources,[t])},_subToEnd:function(t){var n=this,i=function(){return n._removeCur(t)};this._$endHandlers.push({obs:t,handler:i}),t.onEnd(i)},_subscribe:function(t){t.onAny(this._$handleSubAny),this._active&&this._subToEnd(t)},_unsubscribe:function(t){t.offAny(this._$handleSubAny);var n=u(this._$endHandlers,function(n){return n.obs===t});-1!==n&&(t.offEnd(this._$endHandlers[n].handler),this._$endHandlers.splice(n,1))},_handleSubAny:function(t){t.type===on?this._emitValue(t.value):t.type===an&&this._emitError(t.value)},_removeQueue:function(t){var n=s(this._queue,t);return this._queue=a(this._queue,n),n},_removeCur:function(t){this._active&&this._unsubscribe(t);var n=s(this._curSources,t);return this._curSources=a(this._curSources,n),-1!==n&&(0!==this._queue.length?this._pullQueue():0===this._curSources.length&&this._onEmpty()),n},_removeOldest:function(){this._removeCur(this._curSources[0])},_pullQueue:function(){0!==this._queue.length&&(this._queue=o(this._queue),this._addToCur(this._queue.shift()))},_onActivation:function(){for(var t=0,n=this._curSources;t<n.length&&this._active;t++)this._subscribe(n[t])},_onDeactivation:function(){for(var t=0,n=this._curSources;t<n.length;t++)this._unsubscribe(n[t]);null!==this._currentlyAdding&&this._unsubscribe(this._currentlyAdding)},_isEmpty:function(){return 0===this._curSources.length},_onEmpty:function(){},_clear:function(){m.prototype._clear.call(this),this._queue=null,this._curSources=null,this._$handleSubAny=null,this._$endHandlers=null}}),e(Ht,Pt,{_name:"merge",_onEmpty:function(){this._initialised&&this._emitEnd()}}),e(Dt,m,{_name:"repeat",_handleAny:function(t){t.type===un?(this._source=null,this._getSource()):this._emit(t.type,t.value)},_getSource:function(){if(!this._inLoop){this._inLoop=!0;for(var t=this._generator;null===this._source&&this._alive&&this._active;)this._source=t(this._iteration++),this._source?this._source.onAny(this._$handleAny):this._emitEnd();this._inLoop=!1}},_onActivation:function(){this._source?this._source.onAny(this._$handleAny):this._getSource()},_onDeactivation:function(){this._source&&this._source.offAny(this._$handleAny)},_clear:function(){m.prototype._clear.call(this),this._generator=null,this._source=null,this._$handleAny=null}});var le=function(t){return new Dt(t)};e(qt,Pt,{_name:"pool",plug:function(t){return this._add(t),this},unplug:function(t){return this._remove(t),this}}),e(Wt,Pt,{_onActivation:function(){Pt.prototype._onActivation.call(this),this._active&&this._source.onAny(this._$handleMain)},_onDeactivation:function(){Pt.prototype._onDeactivation.call(this),this._source.offAny(this._$handleMain),this._hadNoEvSinceDeact=!0},_handleMain:function(t){if(t.type===on){this._activating&&this._hadNoEvSinceDeact&&this._lastCurrent===t.value||this._add(t.value,this._fn),this._lastCurrent=t.value,this._hadNoEvSinceDeact=!1}t.type===an&&this._emitError(t.value),t.type===un&&(this._isEmpty()?this._emitEnd():this._mainEnded=!0)},_onEmpty:function(){this._mainEnded&&this._emitEnd()},_clear:function(){Pt.prototype._clear.call(this),this._source=null,this._lastCurrent=null,this._$handleMain=null}}),e(Bt,Wt,{_handleMain:function(t){if(t.type===an){this._activating&&this._hadNoEvSinceDeact&&this._lastCurrent===t.value||this._add(t.value,this._fn),this._lastCurrent=t.value,this._hadNoEvSinceDeact=!1}t.type===on&&this._emitValue(t.value),t.type===un&&(this._isEmpty()?this._emitEnd():this._mainEnded=!0)}});var _e={_handlePrimaryValue:function(t){this._lastSecondary!==sn&&this._lastSecondary&&this._emitValue(t)},_handleSecondaryEnd:function(){this._lastSecondary!==sn&&this._lastSecondary||this._emitEnd()}},fe=Ft("filterBy",_e),ce=Qt("filterBy",_e),de=function(t,n){return n},ve={_handlePrimaryValue:function(t){this._lastSecondary!==sn&&this._emitValue(t)},_handleSecondaryEnd:function(){this._lastSecondary===sn&&this._emitEnd()}},pe=Ft("skipUntilBy",ve),me=Qt("skipUntilBy",ve),ye={_handleSecondaryValue:function(){this._emitEnd()}},ge=Ft("takeUntilBy",ye),Ee=Qt("takeUntilBy",ye),be={_init:function(){var t=arguments.length>0&&void 0!==arguments[0]?arguments[0]:{},n=t.flushOnEnd,i=void 0===n||n;this._buff=[],this._flushOnEnd=i},_free:function(){this._buff=null},_flush:function(){null!==this._buff&&(this._emitValue(this._buff),this._buff=[])},_handlePrimaryEnd:function(){this._flushOnEnd&&this._flush(),this._emitEnd()},_onActivation:function(){this._primary.onAny(this._$handlePrimaryAny),this._alive&&null!==this._secondary&&this._secondary.onAny(this._$handleSecondaryAny)},_handlePrimaryValue:function(t){this._buff.push(t)},_handleSecondaryValue:function(){this._flush()},_handleSecondaryEnd:function(){this._flushOnEnd||this._emitEnd()}},Ae=Ft("bufferBy",be),we=Qt("bufferBy",be),Se={_init:function(){var t=arguments.length>0&&void 0!==arguments[0]?arguments[0]:{},n=t.flushOnEnd,i=void 0===n||n,e=t.flushOnChange,r=void 0!==e&&e;this._buff=[],this._flushOnEnd=i,this._flushOnChange=r},_free:function(){this._buff=null},_flush:function(){null!==this._buff&&(this._emitValue(this._buff),this._buff=[])},_handlePrimaryEnd:function(){this._flushOnEnd&&this._flush(),this._emitEnd()},_handlePrimaryValue:function(t){this._buff.push(t),this._lastSecondary===sn||this._lastSecondary||this._flush()},_handleSecondaryEnd:function(){this._flushOnEnd||this._lastSecondary!==sn&&!this._lastSecondary||this._emitEnd()},_handleSecondaryValue:function(t){this._flushOnChange&&!t&&this._flush(),this._lastSecondary=t}},Ve=Ft("bufferWhileBy",Se),Te=Qt("bufferWhileBy",Se),$e=function(){return!1},Ce=function(){return!0},ke={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleValue:function(t){var n=this._fn,i=n(t);i.convert?this._emitError(i.error):this._emitValue(t)}},Oe=B("valuesToErrors",ke),Ie=j("valuesToErrors",ke),xe=function(t){return{convert:!0,error:t}},Le={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleError:function(t){var n=this._fn,i=n(t);i.convert?this._emitValue(i.value):this._emitError(t)}},Pe=B("errorsToValues",Le),He=j("errorsToValues",Le),Me=function(t){return{convert:!0,value:t}},De={_handleError:function(t){this._emitError(t),this._emitEnd()}},Ne=B("endOnError",De),qe=j("endOnError",De);p.prototype.toProperty=function(t){return U(this,t)},p.prototype.changes=function(){return F(this)},p.prototype.toPromise=function(t){return gn(this,t)},p.prototype.toESObservable=J,p.prototype[Sn]=J,p.prototype.map=function(t){return et(this,t)},p.prototype.filter=function(t){return rt(this,t)},p.prototype.take=function(t){return st(this,t)},p.prototype.takeErrors=function(t){return ut(this,t)},p.prototype.takeWhile=function(t){return ot(this,t)},p.prototype.last=function(){return at(this)},p.prototype.skip=function(t){return ht(this,t)},p.prototype.skipWhile=function(t){return lt(this,t)},p.prototype.skipDuplicates=function(t){return _t(this,t)},p.prototype.diff=function(t,n){return ct(this,t,n)},p.prototype.scan=function(t,n){return dt(this,t,n)},p.prototype.flatten=function(t){return vt(this,t)},p.prototype.delay=function(t){return pt(this,t)},p.prototype.throttle=function(t,n){return mt(this,t,n)},p.prototype.debounce=function(t,n){return yt(this,t,n)},p.prototype.mapErrors=function(t){return gt(this,t)},p.prototype.filterErrors=function(t){return Et(this,t)},p.prototype.ignoreValues=function(){return bt(this)},p.prototype.ignoreErrors=function(){return At(this)},p.prototype.ignoreEnd=function(){return wt(this)},p.prototype.beforeEnd=function(t){return St(this,t)},p.prototype.slidingWindow=function(t,n){return Vt(this,t,n)},p.prototype.bufferWhile=function(t,n){return Tt(this,t,n)},p.prototype.bufferWithCount=function(t,n){return $t(this,t,n)},p.prototype.bufferWithTimeOrCount=function(t,n,i){return Ct(this,t,n,i)},p.prototype.transduce=function(t){return Ot(this,t)},p.prototype.withHandler=function(t){return It(this,t)},p.prototype.thru=function(t){return t(this)},p.prototype.combine=function(t,n){return it([this,t],n)},p.prototype.zip=function(t,n){return Lt([this,t],n)},p.prototype.merge=function(t){return Mt([this,t])},p.prototype.concat=function(t){return Nt([this,t])};var We=function(){return new qt};p.prototype.flatMap=function(t){return new Wt(this,t).setName(this,"flatMap")},p.prototype.flatMapLatest=function(t){return new Wt(this,t,{concurLim:1,drop:"old"}).setName(this,"flatMapLatest")},p.prototype.flatMapFirst=function(t){return new Wt(this,t,{concurLim:1}).setName(this,"flatMapFirst")},p.prototype.flatMapConcat=function(t){return new Wt(this,t,{queueLim:-1,concurLim:1}).setName(this,"flatMapConcat")},p.prototype.flatMapConcurLimit=function(t,n){return new Wt(this,t,{queueLim:-1,concurLim:n}).setName(this,"flatMapConcurLimit")},p.prototype.flatMapErrors=function(t){return new Bt(this,t).setName(this,"flatMapErrors")},p.prototype.filterBy=function(t){return zt(this,t)},p.prototype.sampledBy=function(t,n){return Yt(this,t,n)},p.prototype.skipUntilBy=function(t){return Kt(this,t)},p.prototype.takeUntilBy=function(t){return Gt(this,t)},p.prototype.bufferBy=function(t,n){return Jt(this,t,n)},p.prototype.bufferWhileBy=function(t,n){return Rt(this,t,n)};var Be=!0;p.prototype.awaiting=function(t){return rn("You are using deprecated .awaiting() method, see https://github.com/kefirjs/kefir/issues/145"),Xt(this,t)},p.prototype.valuesToErrors=function(t){return rn("You are using deprecated .valuesToErrors() method, see https://github.com/kefirjs/kefir/issues/149"),Zt(this,t)},p.prototype.errorsToValues=function(t){return rn("You are using deprecated .errorsToValues() method, see https://github.com/kefirjs/kefir/issues/149"),tn(this,t)},p.prototype.endOnError=function(){return rn("You are using deprecated .endOnError() method, see https://github.com/kefirjs/kefir/issues/150"),nn(this)};var je={Observable:p,Stream:m,Property:y,never:g,later:b,interval:A,sequentially:w,fromPoll:S,withInterval:T,fromCallback:k,fromNodeCallback:O,fromEvents:P,stream:C,constant:M,constantError:N,fromPromise:Q,fromESObservable:K,combine:it,zip:Lt,merge:Mt,concat:Nt,Pool:qt,pool:We,repeat:le,staticLand:Tn};je.Kefir=je,t.dissableDeprecationWarnings=en,t.Kefir=je,t.Observable=p,t.Stream=m,t.Property=y,t.never=g,t.later=b,t.interval=A,t.sequentially=w,t.fromPoll=S,t.withInterval=T,t.fromCallback=k,t.fromNodeCallback=O,t.fromEvents=P,t.stream=C,t.constant=M,t.constantError=N,t.fromPromise=Q,t.fromESObservable=K,t.combine=it,t.zip=Lt,t.merge=Mt,t.concat=Nt,t.Pool=qt,t.pool=We,t.repeat=le,t.staticLand=Tn,t.default=je,Object.defineProperty(t,"__esModule",{value:!0})}); |
| { | ||
| "name": "kefir", | ||
| "version": "3.8.0", | ||
| "version": "3.8.1", | ||
| "description": "Reactive Programming library for JavaScript inspired by Bacon.js and RxJS with focus on high performance and low memory usage", | ||
@@ -12,5 +12,5 @@ "main": "dist/kefir.js", | ||
| "build": "npm run clean && npm run build-js && npm run build-docs", | ||
| "test": "./configs/prettier.sh check && rollup -c ./configs/rollup.dev.js && jasmine-node --matchall test/specs && flow check", | ||
| "test-only": "rollup -c ./configs/rollup.dev.js && jasmine-node --matchall test/specs", | ||
| "test-debug": "rollup -c ./configs/rollup.dev.js && node --inspect-brk `npm bin`/jasmine-node --matchall test/specs" | ||
| "test": "./configs/prettier.sh check && rollup -c ./configs/rollup.dev.js && mocha && flow check", | ||
| "test-only": "rollup -c ./configs/rollup.dev.js && mocha", | ||
| "test-debug": "rollup -c ./configs/rollup.dev.js && mocha --inspect-brk" | ||
| }, | ||
@@ -33,6 +33,6 @@ "keywords": [ | ||
| "author": "Roman Pominov <rpominov@gmail.com>", | ||
| "homepage": "https://github.com/rpominov/kefir", | ||
| "homepage": "https://github.com/kefirjs/kefir", | ||
| "repository": { | ||
| "type": "git", | ||
| "url": "http://github.com/rpominov/kefir.git" | ||
| "url": "http://github.com/kefirjs/kefir.git" | ||
| }, | ||
@@ -43,5 +43,7 @@ "license": "MIT", | ||
| "babel-preset-es2015-loose-rollup": "7.0.0", | ||
| "flow-bin": "0.50.0", | ||
| "chai": "^4.1.2", | ||
| "chai-kefir": "^2.0.1", | ||
| "flow-bin": "0.62.0", | ||
| "inquirer": "0.10.1", | ||
| "jasmine-node": "1.14.5", | ||
| "mocha": "^4.0.1", | ||
| "prettier": "1.0.2", | ||
@@ -57,2 +59,3 @@ "pug": "2.0.0-beta11", | ||
| "sinon": "1.17.1", | ||
| "sinon-chai": "^2.14.0", | ||
| "transducers-js": "0.4.174", | ||
@@ -59,0 +62,0 @@ "transducers.js": "0.3.2", |
@@ -1,2 +0,2 @@ | ||
| # <a href="http://rpominov.github.io/kefir/"><img src="http://rpominov.github.io/kefir/Kefir-with-bg.svg" width="60" height="60"></a> Kefir | ||
| # <a href="http://kefirjs.github.io/kefir/"><img src="http://kefirjs.github.io/kefir/Kefir-with-bg.svg" width="60" height="60"></a> Kefir | ||
@@ -10,10 +10,10 @@ | ||
| For docs visit [rpominov.github.io/kefir](http://rpominov.github.io/kefir). | ||
| See also [Deprecated API docs](https://github.com/rpominov/kefir/blob/master/deprecated-api-docs.md). | ||
| For docs visit [kefirjs.github.io/kefir](http://kefirjs.github.io/kefir). | ||
| See also [Deprecated API docs](https://github.com/kefirjs/kefir/blob/master/deprecated-api-docs.md). | ||
| [](https://travis-ci.org/rpominov/kefir) | ||
| [](https://david-dm.org/rpominov/kefir) | ||
| [](https://david-dm.org/rpominov/kefir#info=devDependencies) | ||
| [](https://travis-ci.org/kefirjs/kefir) | ||
| [](https://david-dm.org/kefirjs/kefir) | ||
| [](https://david-dm.org/kefirjs/kefir#info=devDependencies) | ||
| [](https://gitter.im/pozadi/kefir?utm_source=badge&utm_medium=badge&utm_campaign=pr-badge) | ||
@@ -39,3 +39,3 @@ | ||
| See [downloads](https://rpominov.github.io/kefir/#downloads) section in the docs. | ||
| See [downloads](https://kefirjs.github.io/kefir/#downloads) section in the docs. | ||
@@ -42,0 +42,0 @@ Also available on [jsDelivr](http://www.jsdelivr.com/#!kefir). |
@@ -414,3 +414,3 @@ import Observable from './observable' | ||
| Observable.prototype.awaiting = function(other) { | ||
| warn('You are using deprecated .awaiting() method, see https://github.com/rpominov/kefir/issues/145') | ||
| warn('You are using deprecated .awaiting() method, see https://github.com/kefirjs/kefir/issues/145') | ||
| return awaiting(this, other) | ||
@@ -423,3 +423,3 @@ } | ||
| Observable.prototype.valuesToErrors = function(fn) { | ||
| warn('You are using deprecated .valuesToErrors() method, see https://github.com/rpominov/kefir/issues/149') | ||
| warn('You are using deprecated .valuesToErrors() method, see https://github.com/kefirjs/kefir/issues/149') | ||
| return valuesToErrors(this, fn) | ||
@@ -432,3 +432,3 @@ } | ||
| Observable.prototype.errorsToValues = function(fn) { | ||
| warn('You are using deprecated .errorsToValues() method, see https://github.com/rpominov/kefir/issues/149') | ||
| warn('You are using deprecated .errorsToValues() method, see https://github.com/kefirjs/kefir/issues/149') | ||
| return errorsToValues(this, fn) | ||
@@ -441,3 +441,3 @@ } | ||
| Observable.prototype.endOnError = function() { | ||
| warn('You are using deprecated .endOnError() method, see https://github.com/rpominov/kefir/issues/150') | ||
| warn('You are using deprecated .endOnError() method, see https://github.com/kefirjs/kefir/issues/150') | ||
| return endOnError(this) | ||
@@ -444,0 +444,0 @@ } |
@@ -55,3 +55,3 @@ import Stream from '../stream' | ||
| // we need to suscribe to _passive_ sources before _active_ | ||
| // (see https://github.com/rpominov/kefir/issues/98) | ||
| // (see https://github.com/kefirjs/kefir/issues/98) | ||
| for (let i = this._activeCount; i < this._sources.length; i++) { | ||
@@ -58,0 +58,0 @@ this._sources[i].onAny(this._$handlers[i]) |
@@ -19,3 +19,3 @@ import {inherit} from '../utils/objects' | ||
| // fix https://github.com/rpominov/kefir/issues/35 | ||
| // fix https://github.com/kefirjs/kefir/issues/35 | ||
| if (!this._active) { | ||
@@ -22,0 +22,0 @@ this._callUnsubscribe() |
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
New alerts
New author
Supply chain riskA new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.
Found 1 instance in 1 package
Improved metrics
- Total package byte prevSize
- increased by22.13%
346551
- Number of package files
- increased by13.27%
111
Worsened metrics
- Dev dependency count
- increased by16.67%
21
- Number of medium supply chain risk alerts
- increased byInfinity%
1
No dependency changes