package sinks
import pubsub "github.com/alash3al/go-pubsub"
type Sink interface {
Subscribe(broker *pubsub.Broker, topic string) error
}