-
operators:
- Add
Stream.asNullable()
operator.
- Add
-
single:
- Add
Single.asNullable()
operator.
- Add
-
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
forNotReplayValueStream
andStateStream
.
- Implement
-
single:
RxSingles.using
- Convert all required positional parameters to required named parameters.
- The
disposer
is now called after the future returned fromStreamSubscription.cancel
completes.
- Remove
Single.fromStream
constructor, useSingle.unsafeFromStream
instead.
-
Docs: update broken doc link (thanks to @dungngminh).
- operators:
- Fix
doOn
operator. Related issue: rxdart#683.
- Fix
-
single:
- Fix
Single.unsafeFromStream
docs
- Fix
-
state_stream:
- Introduce
MutableStateStream<T>
. StateSubject<T>
now implementsMutableStateStream<T>
.- Introduce extension methods on
MutableStateStream<T>
:update()
.getAndUpdate()
.updateAndGet()
.
- Introduce
-
Several docs and example improvements.
-
single:
- Add
RxSingles.using
. - Add
RxSingles.forkJoin3..forkJoin9
andRxSingles.forkJoinList
. - Deprecate
Single.fromStream
, introduceSingle.unsafeFromStream
.
- Add
-
state_stream:
- Internal refactoring of
StateSubject
, fixStateSubject.addStream
. ValueStreamController.sink
now processes events correctly.
- Internal refactoring of
-
Subject.stream
now returns a read-onlyStream
. Previously,Subject.stream
was identical to theSubject
, so we could add events to it, for example:(subject.stream as Sink<T>).add(event)
. This behavior is now disallowed, and will throw aTypeError
if attempted. UseSubject.sink
/Subject
itself for adding events. -
Several docs and example improvements.
-
single:
- Add
Single.toEitherSingle()
. - Add
Single.flatMapEitherSingle()
.
- Add
-
Update docs.
- state_stream:
StateSubject.stream
now returns aStateStream
.- Update docs for
StateSubject
andStateStream
.
- Fix
StateStream.select5..select9
: miss passingequals
param.
- Update
rxdart
to^0.27.5
. - Fix: remove
@internal
onStateStream.asBroadcastStateStream
extension method. Stream.toSingleSubscriptionStream()
now returns a newStream
every call instead of the input stream even if it's a single-subscription Stream.
- Revert
path
to^1.8.0
(becauseflutter_test
from Flutter sdk (>= 2.5.0
) depends on path1.8.0
or1.8.1
).
-
Update
rxdart
to0.27.4
. -
Update
path
to1.8.2
. -
operators:
- Remove
Stream.whereNotNull()
(moved torxdart 0.27.4
as standard operator: mapNotNull). - Remove
Stream.mapNotNull()
(moved torxdart 0.27.4
as standard operator: whereNotNull).
- Remove
-
utils:
- Add
DisposableMixin
. This mixin adds an easy option to dispose Streams without having to store aStreamSubscription
variable. (Thanks to Jop Middelkamp). - Add
Equality
typedef.
- Add
-
state_stream:
- Rename
StateStream.defaultEquals
toStateStream.defaultEquality
. - Add
StateStream
selectors (SelectorsStateStreamExtensions
):StateStream.select
,StateStream.select2
toStateStream.select9
andStateStream.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
toselect9
,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.
- Rename
- Update
rxdart
to0.27.3
. - Refactor
NotReplayValueConnectableStream
andStateConnectableStream
by usingrxdart
' sAbstractConnectableStream
. - Add
StateStream.asBroadcastStateStream
extension method. - Add
Future<void> delay(int milliseconds)
function.
- Update dependencies
rxdart
to0.27.2
meta
to1.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()
.
- Add
- single: Add
Single.retry()
. - operators:
- Add
Stream.doneOnError()
. - Add
Stream.flatMapBatches()
. - Add
Stream.flatMapBatchesSingle()
.
- Add
- Internal: migrated from
pedantic
tolints
.
- Stable release: see change logs of
0.1.1-dev.x
versions.- Add
Single
type. - Operators refactoring.
- Add
- Add
Single.asVoid
. - Refactoring operators.
- Add
Single.mapTo
. - Refactoring operators.
- Change return type of
Stream.ignoreElements()
toStream<Never>
. - Refactor
Single
- Add
Single.fromStream
. - Remove
Single.zip2
(move toRxSingles
). - Add operators
debug
.doOnCancel
.doOnData
.doOnError
.doOnListen
.onErrorResumeNextSingle
.onErrorResumeSingle
.onErrorReturn
.onErrorReturnWith
.
- Add
RxSingles
zip2
.forkJoin2
.
- Add
- Add
Single
.
- Support
rxdart: ^0.27.0
. - Add
asVoid
.
- Add
doOn
extension. - Update dependencies to latest version.
- Add
whereNotNull
. - Update
ignoreElements
andignoreErrors
. - Update
ForwardingSinkMixin
. - Rename
ListenNullStreamExtension
toCollectStreamExtension
. - Update docs.
- Enhance
debug
operator: prints current stacktrace, including location, line and member if not provide the identifier (ie. it isnull
).
- Added
ValueStreamController
: like a single-subscriptionStreamController
except the stream of this controller is a single-subscriptionNotReplayValueStream
. - Added
toNotReplayValueStream
extension: converts aStream
to a single-subscriptionNotReplayValueStream
.
- Now, return type of
collect
isStreamSubscription<T>
.
- Added
distinctBy
. - Removed generic type of
CollectStreamSubscription
.
- Update dependency:
rxdart: ^0.26.0-nullsafety.1
.
- Fix missing exports.
- Initial version.