v2.5.0

Installation

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

Added

• External resource section in the documentation: #301

Changed

• The Range operator was emitting the wrong number of items compared to other Rx implementations: #288
• Handle context priority in SendContext: #300

Fixed

• Documentation: #271, #272, #278, and #290

v1.0.1

• Deprecated version note

v2.4.0

Installation

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

Changed

• Changing the type of the distribution function in the GroupByDynamic operator: #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: #266
• Fixing timestamp documentation: #265

v2.3.0

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: #261

v2.2.0

Installation

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

Added

• GroupByDynamic operator

v2.1.1

Installation

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

Fixed

• Fixing leaks in very specific cases

v2.1.0

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.

v2.0.1

Installation

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

Changed

• Fixing Merge operator behaviour to make sure the observables are emitted sequentially #245

v2.0.0

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

v2.0.0-beta.3

Installation

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

Release

• Fixing time-based observable (Buffer & Window)