Fix streaming filter mode by not running reader callback concurrently

Close #3728

1 files changed, 4 insertions, 0 deletions

diff --git a/src/core.go b/src/core.go
index 8253c49e..3d84c733 100644
--- a/src/core.go
+++ b/src/core.go
@@ -3,6 +3,7 @@ package fzf
 
 import (
 	"fmt"
+	"sync"
 	"time"
 	"unsafe"
 
@@ -164,14 +165,17 @@ func Run(opts *Options, version string, revision string) {
 		found := false
 		if streamingFilter {
 			slab := util.MakeSlab(slab16Size, slab32Size)
+			mutex := sync.Mutex{}
 			reader := NewReader(
 				func(runes []byte) bool {
 					item := Item{}
 					if chunkList.trans(&item, runes) {
+						mutex.Lock()
 						if result, _, _ := pattern.MatchItem(&item, false, slab); result != nil {
 							opts.Printer(item.text.ToString())
 							found = true
 						}
+						mutex.Unlock()
 					}
 					return false
 				}, eventBox, opts.ReadZero, false)