diff options
Diffstat (limited to 'plugins/memory/pubsub.go')
| -rw-r--r-- | plugins/memory/pubsub.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/plugins/memory/pubsub.go b/plugins/memory/pubsub.go index 3c909900..c79f3eb0 100644 --- a/plugins/memory/pubsub.go +++ b/plugins/memory/pubsub.go @@ -17,7 +17,7 @@ type PubSubDriver struct { log logger.Logger } -func NewPubSubDriver(log logger.Logger, _ string) (pubsub.PubSub, error) { +func NewPubSubDriver(log logger.Logger, _ string) (*PubSubDriver, error) { ps := &PubSubDriver{ pushCh: make(chan *pubsub.Message, 10), storage: bst.NewBST(), |