All Operator

Overview

Determine whether all items emitted by an Observable meet some criteria.

Example

observable := rxgo.Just(1, 2, 3, 4)().
	All(func(i interface{}) bool {
		// Check all items are less than 10
		return i.(int) < 10
	})

Output:

true

Options

• WithBufferedChannel

• WithContext

• WithObservationStrategy

• WithErrorStrategy

• WithPool

• WithCPUPool

• WithPublishStrategy