Method Max

observable_operator.go:1519–1526

Max determines and emits the maximum-valued item emitted by an Observable according to a comparator.

(comparator Comparator, opts ...Option)

// Max determines and emits the maximum-valued item emitted by an Observable according to a comparator.
func (o *ObservableImpl) Max(comparator Comparator, opts ...Option) OptionalSingle {
	return optionalSingle(o.parent, o, func() operator {
		return &maxOperator{
			comparator: comparator,
			empty:      true,
		}
	}, false, false, opts...)
}

type maxOperator struct {
	comparator Comparator