Merge pull request #4 from apptreesoftware/master

Unable to cancel subscription
devimteam · Apr 5, 2019 · f6c6292 · f6c6292
2 parents 0e3d309 + bb56e15
commit f6c6292
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/subscriber.go b/subscriber.go
@@ -143,7 +143,7 @@ func (s Subscriber) processEvents(
 			}
 			s.processEvent(d, dataType, eventChan)
 		case <-ctx.Done():
-			if s.opts.processAll && processedAll {
+			if (s.opts.processAll && processedAll) || !s.opts.processAll {
 				close(eventChan)
 				return
 			}