diff options
Diffstat (limited to 'pkg/pubsub/interface.go')
| -rw-r--r-- | pkg/pubsub/interface.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/pkg/pubsub/interface.go b/pkg/pubsub/interface.go index eb65b4b7..4926cad6 100644 --- a/pkg/pubsub/interface.go +++ b/pkg/pubsub/interface.go @@ -1,6 +1,6 @@ package pubsub -import "github.com/spiral/roadrunner/v2/pkg/pubsub/message" +import websocketsv1 "github.com/spiral/roadrunner/v2/pkg/proto/websockets/v1beta" /* This interface is in BETA. It might be changed. @@ -42,5 +42,5 @@ type Publisher interface { // Reader interface should return next message type Reader interface { - Next() (*message.Message, error) + Next() (*websocketsv1.Message, error) } |