@reactive-js/core
Advanced tools
Comparing version 0.0.53 to 0.0.54
@@ -237,10 +237,2 @@ import { Concat, FromArray, FromIterator, Keep, Map, ConcatAll, Zip, ContainerLike } from './container.js'; | ||
/** | ||
* Creates a new `ObservableLike` which applies the provided the operator function to | ||
* observer when the source is subscribed to. | ||
* | ||
* @param operator The operator function to apply. | ||
*/ | ||
declare const lift: <TA, TB>(operator: ObserverOperator<TA, TB>) => ObservableOperator<TA, TB>; | ||
/** | ||
* Returns an `ObservableLike` that applies the `mapper` function to each | ||
@@ -540,9 +532,2 @@ * value emitted by the source. | ||
/** | ||
* A function which transforms a `ObserverLike<B>` to a `ObserverLike<A>`. | ||
*/ | ||
interface ObserverOperator<A, B> { | ||
readonly isSynchronous: boolean; | ||
(observer: ObserverLike<B>): ObserverLike<A>; | ||
} | ||
/** | ||
* The source of notifications which notifies a `ObserverLike` instance. | ||
@@ -604,2 +589,2 @@ * | ||
export { AsyncReducer, DispatcherLike, MulticastObservableLike, ObservableEffectMode, ObservableLike, ObservableOperator, ObserverLike, ObserverOperator, StreamLike, SubjectLike, ThrottleMode, __currentScheduler, __do, __memo, __observe, __using, buffer, catchError, combineLatest, combineLatestWith, concat, concatAll, concatAllT, concatT, createObservable, createSubject, defer, dispatchTo, distinctUntilChanged, exhaust, exhaustT, fromArray, fromArrayT, fromDisposable, fromEnumerable, fromIterable, fromIterator, fromIteratorT, fromPromise, generate, keep, keepT, lift, map, mapAsync, mapT, merge, mergeAll, mergeAllT, mergeWith, never, observable, observe, onNotify, onSubscribe, pairwise, publish, reduce, repeat, retry, scan, scanAsync, share, skipFirst, subscribe, subscribeOn, switchAll, switchAllT, takeFirst, takeLast, takeUntil, takeWhile, throttle, throwIfEmpty, timeout, timeoutError, toEnumerable, toPromise, toRunnable, type, using, withLatestFrom, zip, zipLatest, zipLatestWith, zipT, zipWithLatestFrom }; | ||
export { AsyncReducer, DispatcherLike, MulticastObservableLike, ObservableEffectMode, ObservableLike, ObservableOperator, ObserverLike, StreamLike, SubjectLike, ThrottleMode, __currentScheduler, __do, __memo, __observe, __using, buffer, catchError, combineLatest, combineLatestWith, concat, concatAll, concatAllT, concatT, createObservable, createSubject, defer, dispatchTo, distinctUntilChanged, exhaust, exhaustT, fromArray, fromArrayT, fromDisposable, fromEnumerable, fromIterable, fromIterator, fromIteratorT, fromPromise, generate, keep, keepT, map, mapAsync, mapT, merge, mergeAll, mergeAllT, mergeWith, never, observable, observe, onNotify, onSubscribe, pairwise, publish, reduce, repeat, retry, scan, scanAsync, share, skipFirst, subscribe, subscribeOn, switchAll, switchAllT, takeFirst, takeLast, takeUntil, takeWhile, throttle, throwIfEmpty, timeout, timeoutError, toEnumerable, toPromise, toRunnable, type, using, withLatestFrom, zip, zipLatest, zipLatestWith, zipT, zipWithLatestFrom }; |
{ | ||
"name": "@reactive-js/core", | ||
"version": "0.0.53", | ||
"version": "0.0.54", | ||
"keywords": [ | ||
@@ -45,3 +45,3 @@ "asynchronous", | ||
}, | ||
"gitHead": "d0771a359d176eefc0c4847bb01390e6cdc7d704" | ||
"gitHead": "d91eeafb726d2e2e628fbdb574367614d81ed5b3" | ||
} |
import { FromArray, FromArrayOptions, Keep, ContainerLike, Container, ContainerOf } from './container.js'; | ||
import { SideEffect1, Equality, Predicate, Function1, Updater, Factory, Reducer, Function2, Function3, Function4, Function5 } from './functions.js'; | ||
import { SinkLike, SinkOperator } from './sink.js'; | ||
import { SinkLike } from './sink.js'; | ||
import { Option } from './option.js'; | ||
@@ -34,2 +34,3 @@ import { DisposableLike } from './disposable.js'; | ||
declare type SinkOperator<TA, TB> = Function1<SinkLike<TB>, SinkLike<TA>>; | ||
declare const lift: <TA, TB>(operator: SinkOperator<TA, TB>) => RunnableOperator<TA, TB>; | ||
@@ -36,0 +37,0 @@ |
import { DisposableLike } from './disposable.js'; | ||
import { Function1, Equality, Predicate, SideEffect1, Reducer } from './functions.js'; | ||
import { Equality, Predicate, Function1, SideEffect1, Reducer } from './functions.js'; | ||
import { Option } from './option.js'; | ||
@@ -20,3 +20,2 @@ | ||
} | ||
declare type SinkOperator<TA, TB> = Function1<SinkLike<TB>, SinkLike<TA>>; | ||
declare function notifyDistinctUntilChanged<T>(this: DelegatingSinkLike<T, T> & { | ||
@@ -65,2 +64,2 @@ readonly equality: Equality<T>; | ||
export { DelegatingSinkLike, SinkLike, SinkOperator, notifyDistinctUntilChanged, notifyKeep, notifyMap, notifyOnNotify, notifyPairwise, notifyReduce, notifyScan, notifySkipFirst, notifyTakeFirst, notifyTakeLast, notifyTakeWhile }; | ||
export { DelegatingSinkLike, SinkLike, notifyDistinctUntilChanged, notifyKeep, notifyMap, notifyOnNotify, notifyPairwise, notifyReduce, notifyScan, notifySkipFirst, notifyTakeFirst, notifyTakeLast, notifyTakeWhile }; |
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
469479
12098