refactor: subscriber interface

w-h-a · Jul 13, 2024 · c59a715 · c59a715
1 parent 5b6c66e
commit c59a715
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/streams/subscriber.go b/streams/subscriber.go
@@ -3,8 +3,8 @@ package streams
 type Subscriber interface {
 	Options() SubscribeOptions
 	Channel() chan Event
-	Ack(ev Event) error
-	Nack(ev Event) error
+	Ack(ev Event) interface{}
+	Nack(ev Event) interface{}
 	SetAttempts(c int, ev Event)
 	GetAttempts(ev Event) (int, bool)
 	String() string