From 000ea90877da055852aea97d076ca2d539ff0ea9 Mon Sep 17 00:00:00 2001 From: Todd Gruben Date: Tue, 24 Mar 2020 13:48:29 -0500 Subject: [PATCH] unbuffer channel --- field.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/field.go b/field.go index 64b3a886d..670071c6d 100644 --- a/field.go +++ b/field.go @@ -595,7 +595,7 @@ func (f *Field) Open() error { return errors.Wrap(err, "checking foreign index") } } - f.availableShardChan = make(chan []byte, 1) + f.availableShardChan = make(chan []byte) f.doneChan = make(chan struct{}) f.wg.Add(1) go f.writeAvailableShards()