diff --git a/pkg/pipe/pipe.go b/pkg/pipe/intake.go
similarity index 99%
rename from pkg/pipe/pipe.go
rename to pkg/pipe/intake.go
index cb18290..1740cfb 100644
--- a/pkg/pipe/pipe.go
+++ b/pkg/pipe/intake.go
@@ -109,7 +109,7 @@ func Firehose(ctx context.Context, config FirehoseConfig, check PubkeyChecker, s
 		Since: config.Since(),
 	}
 
-	seen := newBuffer(2048)
+	seen := newBuffer(1024)
 	for event := range pool.SubscribeMany(ctx, config.Relays, filter) {
 		if seen.Contains(event.ID) {
 			// event already seen, skip
diff --git a/pkg/pipe/pipe_test.go b/pkg/pipe/intake_test.go
similarity index 100%
rename from pkg/pipe/pipe_test.go
rename to pkg/pipe/intake_test.go