RxGo

Installation

go get -u github.com/reactivex/rxgo/[email protected]

Added

• External resource section in the documentation: https://github.com/ReactiveX/RxGo/pull/301

Changed

• The Range operator was emitting the wrong number of items compared to other Rx implementations: https://github.com/ReactiveX/RxGo/pull/288
• Handle context priority in SendContext: https://github.com/ReactiveX/RxGo/pull/300

Fixed

• Documentation: https://github.com/ReactiveX/RxGo/pull/271, https://github.com/ReactiveX/RxGo/pull/272, https://github.com/ReactiveX/RxGo/pull/278, and https://github.com/ReactiveX/RxGo/pull/290

• Deprecated version note

Installation

go get -u github.com/reactivex/rxgo/[email protected]

Changed

• Changing the type of the distribution function in the GroupByDynamic operator: https://github.com/ReactiveX/RxGo/pull/267
  The documentation was also updated: https://github.com/ReactiveX/RxGo/blob/6fed2e79a28d2a94fcb9876580134c872c629b04/doc/groupbydynamic.md

Fixed

• Stopping the Take operator Stream when it has received all the items: https://github.com/ReactiveX/RxGo/pull/266
• Fixing timestamp documentation: https://github.com/ReactiveX/RxGo/pull/265

Installation

go get -u github.com/reactivex/rxgo/[email protected]

Added

• Find operator

Changed

• Serialize operator implementation (simplification)
• Documentation improvement

Fixed

• Do not increment Count operator in case of error: https://github.com/ReactiveX/RxGo/pull/261

Installation

go get -u github.com/reactivex/rxgo/[email protected]

Added

• GroupByDynamic operator

Installation

go get -u github.com/reactivex/rxgo/[email protected]

Fixed

• Fixing leaks in very specific cases

Installation

go get -u github.com/reactivex/rxgo/[email protected]

Changed

• Connect returns now the context used for the subscription. It allows getting notified once the subscription has been cancelled.

Installation

go get -u github.com/reactivex/rxgo/[email protected]

Changed

• Fixing Merge operator behaviour to make sure the observables are emitted sequentially https://github.com/ReactiveX/RxGo/pull/245

Installation

go get -u github.com/reactivex/rxgo/[email protected]

Release

General

• Hot vs cold observable
• Backpressure management
• Lazy vs eager observation
• Sequential vs parallel operators
• Connectable Observable
• Observable options

New Operators

• All
• Amb
• Average
• BackOffRetry
• Buffer
• Catch
• CombineLatest
• Concat
• Contains
• Count
• Debounce
• DefaultIfEmpty
• Defer
• ElementAt
• Error
• FirstOrDefault
• FromEventSource
• GroupBy
• IgnoreElements
• Interval
• Join
• LastOrDefault
• Marshal
• Max
• Merge
• Min
• Never
• Range
• Reduce
• Retry
• Run
• Sample
• Scan
• SequenceEqual
• Send
• Serialize
• SkipWhile
• StartWith
• Sum
• TakeUntil
• TakeWhile
• TimeInterval
• Timestamp
• Thrown
• Timer
• ToMap
• ToMapWithValueSelector
• ToSlice
• Unmarshal
• Window
• ZipFromIterable

Installation

go get -u github.com/reactivex/rxgo/[email protected]

Release

• Fixing time-based observable (Buffer & Window)

Installation

go get -u github.com/reactivex/rxgo/[email protected]

Release

• Emphasis on the documentation (update of the README, /doc folder containing the documentation for each operator)
• Connectable Observable (see README documentation)
• Serialize option. To be used in coordination with rxgo.WithPool(n) option.
  Basically, if we want for example to spin up n goroutines to handle a map operation but guarantee that the items will still be emitted sequentially, we can do this:

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))

• New Join operator (thanks to @v-zubko)
• Update of the 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))

• Couple of fixes (missing context propagation mainly) and minor changes
• Improvements of the unit tests (using, for example, a deterministic time API; see https://github.com/ReactiveX/RxGo/issues/233#issuecomment-591512493)

Installation

go get -u github.com/reactivex/rxgo/[email protected]

Release

General

• Hot vs cold observable (see readme)
• Backpressure management (see readme)
• Lazy vs eager observation (see readme)
• Sequential vs parallel operators (see readme)

New Operators

• All
• Amb
• Average
• BackOffRetry
• Buffer
• Catch
• CombineLatest
• Concat
• Contains
• Count
• Debounce
• DefaultIfEmpty
• Defer
• ElementAt
• Error
• FirstOrDefault
• FromEventSource
• GroupBy
• IgnoreElements
• Interval
• LastOrDefault
• Marshal
• Max
• Merge
• Min
• Never
• Range
• Reduce
• Retry
• Run
• Sample
• Scan
• SequenceEqual
• Send
• Serialize
• SkipWhile
• StartWith
• Sum
• TakeUntil
• TakeWhile
• TimeInterval
• Timestamp
• Thrown
• Timer
• ToMap
• ToMapWithValueSelector
• ToSlice
• Unmarshal
• Window
• ZipFromIterable

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!

v1 implementation.