Distinct Operator Overview Suppress duplicate items emitted by an Observable. Example observable := rxgo.Just(1, 2, 2, 3, 4, 4, 5)(). Distinct(func(_ context.Context, i interface{}) (interface{}, error) { return i, nil }) Output: 1 2 3 4 5 Options WithBufferedChannel WithContext WithObservationStrategy WithErrorStrategy WithPool WithCPUPool Serialize Detail WithPublishStrategy
