From 9ae0a30311ca80b647beaa5c018e486a527d7d84 Mon Sep 17 00:00:00 2001
From: Aman Gupta <aman@tmm1.net>
Date: Wed, 9 Oct 2019 18:02:02 -0700
Subject: [PATCH] Fix (*Sink).Close()

The `return` in here seems a mistake added in 43e2faec2d5e84144caf7e3e199729abfb21568e
---
 sink.go | 1 -
 1 file changed, 1 deletion(-)

diff --git a/sink.go b/sink.go
index b66b434..7c65adf 100644
--- 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{}{}