Max Operator

February 25, 2020 · View on GitHub

Overview

Determine, and emit, the maximum-valued item emitted by an Observable.

Example

observable := rxgo.Just(2, 5, 1, 6, 3, 4)().
	Max(func(i1 interface{}, i2 interface{}) int {
		return i1.(int) - i2.(int)
	})

Output:

Options