diff --git a/database/interface.go b/database/interface.go
index d67aaff..12a0f17 100644
--- a/database/interface.go
+++ b/database/interface.go
@@ -307,7 +307,7 @@ func (i *Interface) Subscribe(q *query.Query) (*Subscription, error) {
 		q:        q,
 		local:    i.options.Local,
 		internal: i.options.Internal,
-		Feed:     make(chan record.Record, 100),
+		Feed:     make(chan record.Record, 1000),
 	}
 	c.addSubscription(sub)
 	return sub, nil