diff options
author | Jacob Vosmaer <jacob@gitlab.com> | 2023-03-20 20:02:24 +0300 |
---|---|---|
committer | Jacob Vosmaer <jacob@gitlab.com> | 2023-03-30 18:24:38 +0300 |
commit | 9ab5eff6153a4703d8e9eab3dff49a8d8cb64b44 (patch) | |
tree | e551d1e59eadbc3678484fd3cbbe14e4fcfcbc73 | |
parent | f7f9ba7e0146b6e2a66fd1eb7f6fd0eae8c6c44e (diff) |
Remove unnecessary sync.Once
-rw-r--r-- | internal/streamcache/cache.go | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/internal/streamcache/cache.go b/internal/streamcache/cache.go index 636d8f503..b8d9cd03d 100644 --- a/internal/streamcache/cache.go +++ b/internal/streamcache/cache.go @@ -332,16 +332,13 @@ func runCreate(w io.WriteCloser, create func(io.Writer) error) (err error) { type waiter struct { done chan struct{} err error - once sync.Once } func newWaiter() *waiter { return &waiter{done: make(chan struct{})} } func (w *waiter) SetError(err error) { - w.once.Do(func() { - w.err = err - close(w.done) - }) + w.err = err + close(w.done) } func (w *waiter) Wait(ctx context.Context) error { |