package sinks

import pubsub "github.com/alash3al/go-pubsub"

type Sink interface {
	Subscribe(broker *pubsub.Broker, topic string) error
}