diff options
| author | Valery Piashchynski <[email protected]> | 2021-08-18 00:27:08 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-08-18 00:27:08 +0300 |
| commit | 300560b44451bd9d5241ccdbaea3576760968ef2 (patch) | |
| tree | 88d7d862707ae135f8c345e59111f2b2b9dff60f /common | |
| parent | 65a70f5d15fb0a1b1f787ff7f06b3a299dab0f96 (diff) | |
Update broadcast tests, improve stop mechanism.
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'common')
| -rw-r--r-- | common/pubsub/interface.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/common/pubsub/interface.go b/common/pubsub/interface.go index 06252d70..5b69d577 100644 --- a/common/pubsub/interface.go +++ b/common/pubsub/interface.go @@ -1,5 +1,7 @@ package pubsub +import "context" + /* This interface is in BETA. It might be changed. */ @@ -45,7 +47,7 @@ type Publisher interface { // Reader interface should return next message type Reader interface { - Next() (*Message, error) + Next(ctx context.Context) (*Message, error) } // Constructor is a special pub-sub interface made to return a constructed PubSub type |