Bot releases are visible (Hide)
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
Published by teivah over 3 years ago
Published by teivah almost 4 years ago
go get -u github.com/reactivex/rxgo/[email protected]
GroupByDynamic
operator: https://github.com/ReactiveX/RxGo/pull/267Take
operator Stream when it has received all the items: https://github.com/ReactiveX/RxGo/pull/266
Published by teivah almost 4 years ago
go get -u github.com/reactivex/rxgo/[email protected]
Find
operatorSerialize
operator implementation (simplification)Published by teivah about 4 years ago
Published by teivah about 4 years ago
go get -u github.com/reactivex/rxgo/[email protected]
Published by teivah over 4 years ago
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.Published by teivah over 4 years ago
go get -u github.com/reactivex/rxgo/[email protected]
Published by teivah over 4 years ago
go get -u github.com/reactivex/rxgo/[email protected]
Published by teivah over 4 years ago
go get -u github.com/reactivex/rxgo/[email protected]
Published by teivah over 4 years ago
go get -u github.com/reactivex/rxgo/[email protected]
rxgo.WithPool(n)
option.Map(func(_ context.Context, item interface{}) (interface{}, error) {
// Map implementation
},
// Create multiple instances of the map operator
rxgo.WithPool(pool),
// Serialize the items emitted by their Customer.ID
rxgo.Serialize(func(item interface{}) int {
customer := item.(Customer)
return customer.ID
}), rxgo.WithBufferedChannel(1))
Join
operator (thanks to @v-zubko)Just
operator for more syntactic sugar (allows to pass variadic arguments for the items and the options)Example:
rxgo.Just(1, 2, 3)(rxgo.WithContext(ctx), rxgo.WithBufferedChannel(5))
Published by teivah over 4 years ago
go get -u github.com/reactivex/rxgo/[email protected]
In total, the v2 contains 87 different operators.
Make sure to check the documentation (develop
branch) and to raise any issues you'd find out!
Published by teivah over 5 years ago
v1 implementation.