End subscription context is cancelled and processAll is false

Matthew Smith · Matthew Smith · commit bb56e152d3bf · 2019-04-05T07:26:38.000-07:00
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
 			}

Original file line number	Diff line number	Diff line change
`@@ -143,7 +143,7 @@ func (s Subscriber) processEvents(`
`143`	`143`	`}`
`144`	`144`	`s.processEvent(d, dataType, eventChan)`
`145`	`145`	`case <-ctx.Done():`
`146`		`- if s.opts.processAll && processedAll {`
	`146`	`+ if (s.opts.processAll && processedAll) \|\| !s.opts.processAll {`
`147`	`147`	`close(eventChan)`
`148`	`148`	`return`
`149`	`149`	`}`