rxdart_ext

https://pub.dev/packages/rxdart_ext/versions/0.3.0

• 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).

What's Changed

• chore(readme): Update broken document link by @dungngminh in #95
• chore(deps): update actions/checkout action to v4 by @renovate in #93
• fix(deps): update dependency http to v1 by @renovate in #91
• fix(deps): update dependency http to v1.2.0 by @renovate in #96
• deps: rxdart: ^0.28.0-dev.1 by @hoc081098 in #97
• chore(deps): update codecov/codecov-action action to v3.1.6 by @renovate in #89
• fix(deps): update dependency http to v1.2.1 by @renovate in #99

New Contributors

• @dungngminh made their first contribution in #95

Full Changelog: 0.2.9...0.3.0

• 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).

https://pub.dev/packages/rxdart_ext/versions/0.2.9

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

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

https://pub.dev/packages/rxdart_ext/versions/0.2.8

• 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.

Full Changelog: 0.2.7...0.2.8

• 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.

https://pub.dev/packages/rxdart_ext/versions/0.2.7

• 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.

What's Changed

• feat(RxSingles.using): add RxSingles.using by @hoc081098 in #77
• test: refactor all by @hoc081098 in #78
• fix(subject): Subject.stream now returns a read-only Stream, fix StateSubject.addStream, add more tests by @hoc081098 in #79
• feat(single): add RxSingles.forkJoin3..forkJoin9 and RxSingles.forkJoinList by @hoc081098 in #80
• refactor(single): deprecate Single.fromStream, introduce Single.unsafeFromStream by @hoc081098 in #81
• chore(publish): prepare for 0.2.7 by @hoc081098 in #82

Full Changelog: 0.2.6...0.2.7

• 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.

https://pub.dev/packages/rxdart_ext/versions/0.2.6

• single:

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

• Update docs.

What's Changed

• fix(deps): update dependency http to v0.13.5 by @renovate in #71
• add toEitherSingle by @hoc081098 in #73
• chore(deps): update codecov/codecov-action action to v3.1.1 by @renovate in #74

Full Changelog: 0.2.5...0.2.6

• single:

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

• Update docs.

https://pub.dev/packages/rxdart_ext/versions/0.2.5

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

What's Changed

• refactor(state): StateSubject.stream returns a StateStream, updat… by @hoc081098 in #69

Full Changelog: 0.2.4...0.2.5

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

https://pub.dev/packages/rxdart_ext/versions/0.2.4

• Fix StateStream.select5..select9: miss passing equals param.

What's Changed

• fix(state_stream/selector): miss passing equals param when using `s… by @hoc081098 in #67

Full Changelog: 0.2.3...0.2.4

• Fix StateStream.select5..select9: miss passing equals param.

https://pub.dev/packages/rxdart_ext/versions/0.2.3

• Fix: remove @internal on StateStream.asBroadcastStateStream extension method.
• Stream.toSingleSubscriptionStream() now returns a new Stream every call
  instead of the input stream even if it's a single-subscription Stream.

What's Changed

• test(flatMapBatches): add forward inner errors test by @hoc081098 in #64
• prepare for v0.2.3 by @hoc081098 in #65

Full Changelog: 0.2.2...0.2.3

• Update rxdart to ^0.27.5.
• Fix: remove @internal on StateStream.asBroadcastStateStream extension method.
• Stream.toSingleSubscriptionStream() now returns a new Stream every call instead of the input stream even if it's a single-subscription Stream.

https://pub.dev/packages/rxdart_ext/versions/0.2.2

• Revert path to ^1.8.0 (because flutter_test from Flutter sdk (>= 2.5.0) depends on path 1.8.0 or 1.8.1).

• Revert path to ^1.8.0 (because flutter_test from Flutter sdk (>= 2.5.0) depends on path 1.8.0 or 1.8.1).

https://pub.dev/packages/rxdart_ext/versions/0.2.1

• 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).

What's Changed

• Update codecov/codecov-action action to v3 by @renovate in #58
• chore(deps): update codecov/codecov-action action to v3.1.0 by @renovate in #59
• deps: rxdart 0.27.4 by @hoc081098 in #60

Full Changelog: 0.2.0...0.2.1

• 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.

• Update rxdart to 0.27.3.
• Refactor NotReplayValueConnectableStream and StateConnectableStream by using rxdart' s AbstractConnectableStream.
• Add StateStream.asBroadcastStateStream extension method.
• Add Future<void> delay(int milliseconds) function.

• Update dependencies
  • rxdart to 0.27.2
  • meta to 1.7.0
• Split into multiple libraries:
  • not_replay_value_stream
  • operators
  • single
  • state_stream
  • utils
  • rxdart_ext: includes all the above.
• utils: Add Sink<void>.addNull() extension.
• state_stream:
  • Add StateStream
  • Add StateSubject.
  • Add StateConnectableStream, Stream.publishState(), Stream.shareState().
• single: Add Single.retry().
• operators:
  • Add Stream.doneOnError().
  • Add Stream.flatMapBatches().
  • Add Stream.flatMapBatchesSingle().
• Internal: migrated from pedantic to lints.

• Stable release: see change logs of 0.1.1-dev.x versions.
  • Add Single type.
  • Operators refactoring.

• Add Single.asVoid.
• Refactoring operators.

• Add Single.mapTo.
• Refactoring operators.

• Change return type of Stream.ignoreElements() to Stream<Never>.
• Refactor Single
  • Add Single.fromStream.
  • Remove Single.zip2 (move to RxSingles).
  • Add operators
    • debug.
    • doOnCancel.
    • doOnData.
    • doOnError.
    • doOnListen.
    • onErrorResumeNextSingle.
    • onErrorResumeSingle.
    • onErrorReturn.
    • onErrorReturnWith.
  • Add RxSingles
    • zip2.
    • forkJoin2.

• Add Single.

• Support rxdart: ^0.27.0.
• Add asVoid.

• Add doOn extension.
• Update dependencies to latest version.

• Add whereNotNull.
• Update ignoreElements and ignoreErrors.
• Update ForwardingSinkMixin.
• Rename ListenNullStreamExtension to CollectStreamExtension.
• Update docs.

• Enhance debug operator: prints current stacktrace, including location, line and member if not provide the identifier (ie. it is null).

• Added ValueStreamController: like a single-subscription StreamController except the stream of this controller is a single-subscription NotReplayValueStream.
• Added toNotReplayValueStream extension: converts a Stream to a single-subscription NotReplayValueStream.

• Now, return type of collect is StreamSubscription<T>.

• Added distinctBy.
• Removed generic type of CollectStreamSubscription.

• Update dependency: rxdart: ^0.26.0-nullsafety.1.

• Fix missing exports.

• Initial version.