Reactive Extensions for the Go language.
go get -u github.com/reactivex/rxgo/[email protected]
Range operator was emitting the wrong number of items compared to other Rx implementations: https://github.com/ReactiveX/RxGo/pull/288
SendContext: https://github.com/ReactiveX/RxGo/pull/300
go get -u github.com/reactivex/rxgo/[email protected]
GroupByDynamic operator: https://github.com/ReactiveX/RxGo/pull/267
The documentation was also updated: https://github.com/ReactiveX/RxGo/blob/6fed2e79a28d2a94fcb9876580134c872c629b04/doc/groupbydynamic.md
Take operator Stream when it has received all the items: https://github.com/ReactiveX/RxGo/pull/266
go get -u github.com/reactivex/rxgo/[email protected]
Find operatorSerialize operator implementation (simplification)go get -u github.com/reactivex/rxgo/[email protected]
go get -u github.com/reactivex/rxgo/[email protected]
Connect returns now the context used for the subscription. It allows getting notified once the subscription has been cancelled.go get -u github.com/reactivex/rxgo/[email protected]
go get -u github.com/reactivex/rxgo/[email protected]
go get -u github.com/reactivex/rxgo/[email protected]