Use empty struct for close channel.
This commit is contained in:
parent
758899b745
commit
2a47829164
|
@ -62,7 +62,7 @@ type asyncSubscriberNats struct {
|
|||
client NatsClient
|
||||
|
||||
receiver chan *nats.Msg
|
||||
closeChan chan bool
|
||||
closeChan chan struct{}
|
||||
subscription NatsSubscription
|
||||
|
||||
processMessage func(*nats.Msg)
|
||||
|
@ -80,7 +80,7 @@ func newAsyncSubscriberNats(key string, client NatsClient) (*asyncSubscriberNats
|
|||
client: client,
|
||||
|
||||
receiver: receiver,
|
||||
closeChan: make(chan bool),
|
||||
closeChan: make(chan struct{}),
|
||||
subscription: sub,
|
||||
}
|
||||
return result, nil
|
||||
|
|
Loading…
Reference in New Issue