Merge pull request 'fix impl interface' (#346 ) from devstigneev/micro:fix_impl_mevent into v3

Reviewed-on: #346
fix impl interface
2024-07-01 12:26:53 +03:00 · 2024-07-01 09:47:51 +03:00
2 changed files with 8 additions and 0 deletions
--- a/broker/memory/memory.go
+++ b/broker/memory/memory.go
@@ -373,6 +373,10 @@ func (m *memoryEvent) SetError(err error) {
 	m.err = err
 }

+func (m *memoryEvent) Context() context.Context {
+	return m.opts.Context
+}
+
 func (m *memorySubscriber) Options() broker.SubscribeOptions {
 	return m.opts
 }
--- a/network/tunnel/broker/broker.go
+++ b/network/tunnel/broker/broker.go
@@ -305,6 +305,10 @@ func (t *tunEvent) SetError(err error) {
 	t.err = err
 }

+func (t *tunEvent) Context() context.Context {
+	return context.TODO()
+}
+
 // NewBroker returns new tunnel broker
 func NewBroker(opts ...broker.Option) (broker.Broker, error) {
 	options := broker.NewOptions(opts...)
Author	SHA1	Message	Date
Василий Толстов	7dc8f088c9	Merge pull request 'fix impl interface' (#346 ) from devstigneev/micro:fix_impl_mevent into v3 Reviewed-on: #346	2024-07-01 12:26:53 +03:00
devstigneev	c65afcea1b	fix impl interface Some checks failed lint / lint (pull_request) Has been cancelled Details pr / test (pull_request) Has been cancelled Details	2024-07-01 09:47:51 +03:00