You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
The DoStreamTransformer seems to be the only transformer that uses forwardStream with listenOnlyOnce argument equal to true. Don't exactly now what is the purpose of this argument, but it leads to some unexpected behavior in the following case:
var s =BehaviorSubject<dynamic>()..add(1);
var stream = s.doOnData((_) {});
var s1 = stream.listen((v) {
print('$v'); // prints 1
});
await stream.first; // completes with value 1await stream.first; // NEVER COMPLETESawait s1.cancel();
The text was updated successfully, but these errors were encountered:
I have seen this issue too, but if we use Stream.multi for doOnXXX, doOnXXX's callback will fire many times even source Stream is broadcast. #412 (comment)
The
DoStreamTransformer
seems to be the only transformer that usesforwardStream
withlistenOnlyOnce
argument equal totrue
. Don't exactly now what is the purpose of this argument, but it leads to some unexpected behavior in the following case:The text was updated successfully, but these errors were encountered: