max.md

Max Operator

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:

6

Options

• WithBufferedChannel

• WithContext

• WithObservationStrategy

• WithErrorStrategy

• WithPool

• WithCPUPool

• WithPublishStrategy