diff --git a/async_events_nats.go b/async_events_nats.go index 04699c6..8742707 100644 --- a/async_events_nats.go +++ b/async_events_nats.go @@ -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