[pubsub] return subscription id in memory implementation

capcom6 · capcom6 · commit 84dfae959f93 · 2025-10-10T17:27:16.000+07:00
diff --git a/pkg/pubsub/memory.go b/pkg/pubsub/memory.go
@@ -103,7 +103,7 @@ func (m *memoryPubSub) Subscribe(ctx context.Context, topic string) (*Subscripti
 		m.wg.Done()
 	}()
 
-	return &Subscription{ctx: subCtx, cancel: cancel, ch: ch}, nil
+	return &Subscription{id: id, ctx: subCtx, cancel: cancel, ch: ch}, nil
 }
 
 func (m *memoryPubSub) subscribe(id, topic string, ch chan Message) {

Original file line number	Diff line number	Diff line change
`@@ -103,7 +103,7 @@ func (m memoryPubSub) Subscribe(ctx context.Context, topic string) (Subscripti`
`103`	`103`	`m.wg.Done()`
`104`	`104`	`}()`
`105`	`105`
`106`		`- return &Subscription{ctx: subCtx, cancel: cancel, ch: ch}, nil`
	`106`	`+ return &Subscription{id: id, ctx: subCtx, cancel: cancel, ch: ch}, nil`
`107`	`107`	`}`
`108`	`108`
`109`	`109`	`func (m *memoryPubSub) subscribe(id, topic string, ch chan Message) {`