Do not increment Count operator in case of error (#261)

ReactiveX · Oct 28, 2020 · 3d2c2bf · 3d2c2bf
1 parent a2dd674
commit 3d2c2bf
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/observable_operator.go b/observable_operator.go
@@ -657,7 +657,6 @@ func (op *countOperator) next(_ context.Context, _ Item, _ chan<- Item, _ operat
 }
 
 func (op *countOperator) err(_ context.Context, _ Item, _ chan<- Item, operatorOptions operatorOptions) {
-	op.count++
 	operatorOptions.stop()
 }