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

teivah · web-flow · commit 3d2c2bf0c892 · 2020-10-28T09:11:29.000+01:00
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()
 }
 

Original file line number	Diff line number	Diff line change
`@@ -657,7 +657,6 @@ func (op *countOperator) next(_ context.Context, _ Item, _ chan<- Item, _ operat`
`657`	`657`	`}`
`658`	`658`
`659`	`659`	`func (op *countOperator) err(_ context.Context, _ Item, _ chan<- Item, operatorOptions operatorOptions) {`
`660`		`- op.count++`
`661`	`660`	`operatorOptions.stop()`
`662`	`661`	`}`
`663`	`662`