diff --git a/contrib/extension/subscription/client.go b/contrib/extension/subscription/client.go
index 86a34c90b3e0536870fc621c4e4910ac9cbfadb6..22d65d703f28e0ec73530b8c757b9d080d85e662 100644
--- a/contrib/extension/subscription/client.go
+++ b/contrib/extension/subscription/client.go
@@ -87,6 +87,7 @@ func (c *WrapClient) Subscribe(ctx context.Context, namespace string, channel an
 		// BUG: a worse is better solution... it means that when this fills, you might receive subscriptions in an undefined error
 		onmsg:   make(chan json.RawMessage, 32),
 		subdone: make(chan struct{}),
+		readErr: make(chan error),
 	}
 
 	// will get the type of the event