Sum Operator

Overview

Calculate the sum of numbers emitted by an Observable and emit this sum.

Instances

• SumFloat32
• SumFloat64
• SumInt64

Example

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

Output:

10

Options

• WithBufferedChannel

• WithContext

• WithObservationStrategy

• WithErrorStrategy

• WithPool

• WithCPUPool

• WithPublishStrategy