Count Operator

Overview

Count the number of items emitted by the source Observable and emit only this value.

Example

observable := rxgo.Just(1, 2, 3)().Count()

Output:

3

Options

• WithBufferedChannel

• WithContext

• WithObservationStrategy

• WithErrorStrategy

• WithPublishStrategy