rxdart_ext 0.3.0

rxdart_ext: ^0.3.0 copied to clipboard

Accept Dart SDK versions above 3.0 (sdk: '>=2.12.0 <4.0.0').

Only support rxdart: ^0.28.0.

state_stream and not_replay_value_stream:

• Implement lastEventOrNull for NotReplayValueStream and StateStream.

single:

• RxSingles.using
  • Convert all required positional parameters to required named parameters.
  • The disposer is now called after the future returned from StreamSubscription.cancel completes.
• Remove Single.fromStream constructor, use Single.unsafeFromStream instead.

Docs: update broken doc link (thanks to @dungngminh).

• Fix doOn operator. Related issue: rxdart#683.

single:

• Fix Single.unsafeFromStream docs

state_stream:

• Introduce MutableStateStream<T>.
• StateSubject<T> now implements MutableStateStream<T>.
• Introduce extension methods on MutableStateStream<T>:
  • update().
  • getAndUpdate().
  • updateAndGet().

Several docs and example improvements.

single:

• Add RxSingles.using.
• Add RxSingles.forkJoin3..forkJoin9 and RxSingles.forkJoinList.
• Deprecate Single.fromStream, introduce Single.unsafeFromStream.

state_stream:

• Internal refactoring of StateSubject, fix StateSubject.addStream.
• ValueStreamController.sink now processes events correctly.

Subject.stream now returns a read-only Stream. Previously, Subject.stream was identical to the Subject, so we could add events to it, for example: (subject.stream as Sink<T>).add(event). This behavior is now disallowed, and will throw a TypeError if attempted. Use Subject.sink/Subject itself for adding events.

Several docs and example improvements.

single:

• Add Single.toEitherSingle().
• Add Single.flatMapEitherSingle().

Update docs.

• StateSubject.stream now returns a StateStream.
• Update docs for StateSubject and StateStream.

Update rxdart to 0.27.4.

Update path to 1.8.2.

operators:

• Remove Stream.whereNotNull() (moved to rxdart 0.27.4 as standard operator: mapNotNull).
• Remove Stream.mapNotNull() (moved to rxdart 0.27.4 as standard operator: whereNotNull).

utils:

• Add DisposableMixin. This mixin adds an easy option to dispose Streams without having to store a StreamSubscription variable. (Thanks to Jop Middelkamp).
• Add Equality typedef.

state_stream:

• Rename StateStream.defaultEquals to StateStream.defaultEquality.
• Add StateStream selectors (SelectorsStateStreamExtensions): StateStream.select, StateStream.select2 to StateStream.select9 and StateStream.selectMany.
  • Select a sub state slice from state stream. Inspirited by NgRx memoized selector
  • Selectors can compute derived data, to store the minimal possible state.
  • Selectors are efficient. A selector is not recomputed unless one of its arguments changes.
  • When using the select, select2 to select9, selectMany functions, keeps track of the latest arguments in which your selector function was invoked. Because selectors are pure functions, the last result can be returned when the arguments match without re-invoking your selector function. This can provide performance benefits, particularly with selectors that perform expensive computation. This practice is known as memoization.

• rxdart to 0.27.2
• meta to 1.7.0

• not_replay_value_stream
• operators
• single
• state_stream
• utils
• rxdart_ext: includes all the above.

• Add StateStream
• Add StateSubject.
• Add StateConnectableStream, Stream.publishState(), Stream.shareState().

• Add Stream.doneOnError().
• Add Stream.flatMapBatches().
• Add Stream.flatMapBatchesSingle().

• Add Single type.
• Operators refactoring.

• Add Single.fromStream.
• Remove Single.zip2 (move to RxSingles).
• Add operators
  • debug.
  • doOnCancel.
  • doOnData.
  • doOnError.
  • doOnListen.
  • onErrorResumeNextSingle.
  • onErrorResumeSingle.
  • onErrorReturn.
  • onErrorReturnWith.
• Add RxSingles
  • zip2.
  • forkJoin2.