rxdart
rxdart copied to clipboard
ReactiveX
The Reactive Extensions for Dart
Hello! After I have upgraded from rxdart 0.27.1 to 0.27.5, my tests have started failing. I found the test starts failing from rxdart 0.27.2: ```dart import 'package:flutter_test/flutter_test.dart'; import 'package:rxdart/subjects.dart'; void...
I'm pretty new to this Dart stream stuff so maybe I'm missing something. But, is it possible to have a distinct ValueStream? The distinct method of the ValueStream class returns...
``` ----0----1-----2-----3----4----5--------- -------------@-------------------@ CURRENT BEHAVIOR --------------------------------------------- -0-1-| -2-3-4-| EXPECTED BEHAVIOR --------------------------------------------- ----0----1---| -2-----3----4----5--| ``` 
Sorry if this maybe is a question, but I don't think that `shareValue()` is behaving as it was expected to (or at least how I understood it was supposed to...
Add isClose verification before _add, avoiding setting newValue when the subject is closed.
In order to deterministically test async code, the `fakeAsync` package currently seems to be the way to go. Unfortunately, it cannot modify the `StopWatch` from `dart:core`, and instead [it is...
Issue #660. - Replace `DateTime.now()` with `clock.now()`. - Replace `Stopwatch` with `clock.stopwatch()`. _I don't know if this can cause any breaking changes?_
update older version of the Android embedding,update UI search_widget…and indicator for data loading 
Code below works fine ``` .groupBy((event) => event.type) .flatMap((groupByType) => groupByType.toSet().asStream()) ``` But if you change to this - onNext never called because of groupByType.toSet() never completes ``` .groupBy((event) =>...
Below is an error on behaviorsubject when .sink.add called more than once this error is not always happen sample code: //initialization final _orders = BehaviorSubject(); //update update() { _order.sink.add('xyz'); }...
