Closed dalewking closed 4 years ago
Actually it was pretty easy to convert using https://pub.dev/packages/rxdart_codemod, Afterword, I think you only need to:
@override
StreamSubscription<TResult> listen(void onData(TResult event),
{Function onError, void onDone(), bool cancelOnError}) =>
_resultsSubject.listen(onData, onError: onError, onDone: onDone, cancelOnError: cancelOnError);
Haven't tested it yet. I'll see if I can whip up a PR for it.
It's on my todo list :-) a PR would be great.
Done with new Version 5.0.0
Rxdart 0.23.1 is a major change and eliminates the Observable class.