Contains Operator

Overview

Determine whether an Observable emits a particular item or not.

Example

observable := rxgo.Just(1, 2, 3)().Contains(func(i interface{}) bool {
	return i == 2
})

Output:

true

Options

• WithBufferedChannel

• WithContext

• WithPool

• WithCPUPool

• WithObservationStrategy

• WithErrorStrategy

• WithPublishStrategy