diff --git a/pubsub.go b/pubsub.go index c6de162..3536a1f 100644 --- a/pubsub.go +++ b/pubsub.go @@ -218,8 +218,9 @@ type PubSub interface { GetChannels() []*Channel GetPipes() []*Pipe Pipe(pipeClient *PipeClient, pipes []*Pipe) error - Sub(sub *Sub, channels []*Channel) error - Pub(pub *Pub, channel []*Channel) error + AddChannel(*Channel) error + Sub(sub *Sub, matcher func(sub *Sub, ch *Channel) bool) error + Pub(pub *Pub, matcher func(pub *Pub, ch *Channel) bool) error } type Cfg struct {