diff --git a/pkg/ingester/tailer.go b/pkg/ingester/tailer.go
index 753862619c3da..25fdfdb740d7a 100644
--- a/pkg/ingester/tailer.go
+++ b/pkg/ingester/tailer.go
@@ -116,10 +116,10 @@ func (t *tailer) loop() {
 }
 
 func (t *tailer) receiveStreamsLoop() {
+	defer t.close()
 	for {
 		select {
 		case <-t.conn.Context().Done():
-			t.close()
 			return
 		case <-t.closeChan:
 			return