merch-tracker-v2/mt-rabbit
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

read only chan

Browse source
This commit is contained in:
nquidox 2026-02-21 15:55:29 +03:00
parent 40d1d3dd29
commit c8a6a7f8fa
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
consumer.go
View file

@ -9,14 +9,14 @@ import (
) )
type Consumer interface { type Consumer interface {
Start(ctx context.Context, chanLen uint) chan []byte Start(ctx context.Context, chanLen uint) <-chan []byte
} }
type consumeHandler struct { type consumeHandler struct {
client *Client client *Client
} }
func (c *consumeHandler) Start(ctx context.Context, chanLen uint) chan []byte { func (c *consumeHandler) Start(ctx context.Context, chanLen uint) <-chan []byte {
msgCh := make(chan []byte, chanLen) msgCh := make(chan []byte, chanLen)
go runConsumer(ctx, c.client, msgCh) go runConsumer(ctx, c.client, msgCh)