diff --git a/messaging/fanout.go b/messaging/fanout.go
index 83cf36e..6bbd2be 100644
--- a/messaging/fanout.go
+++ b/messaging/fanout.go
@@ -3,7 +3,6 @@ package messaging
 import (
 	"context"
 	"go.uber.org/zap"
-	"io"
 	"sync"
 	"sync/atomic"
 )
@@ -117,9 +116,6 @@ func (c *worker) stream(val interface{}) {
 							zap.Error(err),
 						)
 					}
-					if err == io.EOF {
-						return
-					}
 				}
 			default:
 				atomic.AddUint32(&idle, 1)