Merge pull request #5 from tmm1/patch-1

Fix (*Sink).Close()
grafov · Nov 4, 2019 · 66b49ee · 66b49ee
2 parents ccb6fc7 + 9ae0a30
commit 66b49ee
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/sink.go b/sink.go
@@ -306,7 +306,6 @@ func (s *Sink) Start() *Sink {
 
 // Close closes the sink. It flushes records for the sink before closing.
 func (s *Sink) Close() {
-	return
 	if atomic.LoadInt32(s.state) > sinkClosed {
 		atomic.StoreInt32(s.state, sinkClosed)
 		s.close <- struct{}{}