Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

@reactive-js/core

Package Overview
Dependencies
Maintainers
1
Versions
146
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@reactive-js/core - npm Package Compare versions

Comparing version 0.0.53 to 0.0.54

17

observable.d.ts

@@ -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 };

4

package.json
{
"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

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc