Remove unnecessary reader barrier on --filter mode

1 files changed, 2 insertions, 2 deletions

diff --git a/src/core.go b/src/core.go
index d9d98d18..c5ad2353 100644
--- a/src/core.go
+++ b/src/core.go
@@ -139,7 +139,7 @@ func Run(opts *Options, revision string) {
 	if !streamingFilter {
 		reader = NewReader(func(data []byte) bool {
 			return chunkList.Push(data)
-		}, eventBox, opts.ReadZero)
+		}, eventBox, opts.ReadZero, opts.Filter == nil)
 		go reader.ReadSource()
 	}
 
@@ -183,7 +183,7 @@ func Run(opts *Options, revision string) {
 						}
 					}
 					return false
-				}, eventBox, opts.ReadZero)
+				}, eventBox, opts.ReadZero, false)
 			reader.ReadSource()
 		} else {
 			eventBox.Unwatch(EvtReadNew)