From 3d2c2bf0c8927f0e5736851aac501de880bb1ada Mon Sep 17 00:00:00 2001
From: Teiva Harsanyi <teiva.harsanyi@gmail.com>
Date: Wed, 28 Oct 2020 09:11:29 +0100
Subject: [PATCH] Do not increment Count operator in case of error (#261)

---
 observable_operator.go | 1 -
 1 file changed, 1 deletion(-)

diff --git a/observable_operator.go b/observable_operator.go
index 777bcfa8..766eae9b 100644
--- 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()
 }