Filter Operator

Overview

Emit only those items from an Observable that pass a predicate test.

Example

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

Output:

1
3

Options

• WithBufferedChannel

• WithContext

• WithObservationStrategy

• WithErrorStrategy

• WithPool

• WithCPUPool

Serialize

Detail

• WithPublishStrategy