diff --git a/publisher.go b/publisher.go
index 0743889..a65154a 100644
--- a/publisher.go
+++ b/publisher.go
@@ -8,7 +8,7 @@ import (
 )
 
 type Publisher interface {
-	Start(chanLen uint) chan<- []byte
+	Start(ctx context.Context, chanLen uint) chan<- []byte
 }
 
 type pubHandler struct {