Remove unused error result (was always "nil").

This commit is contained in:
Joachim Bauch 2020-07-31 15:23:41 +02:00
parent 5964a98218
commit 6ffed30ddc
Failed to extract signature

View file

@ -66,14 +66,13 @@ func (s *loopbackNatsSubscription) Unsubscribe() error {
return nil
}
func (s *loopbackNatsSubscription) queue(msg *nats.Msg) error {
func (s *loopbackNatsSubscription) queue(msg *nats.Msg) {
s.cond.L.Lock()
s.incoming = append(s.incoming, msg)
if len(s.incoming) == 1 {
s.cond.Signal()
}
s.cond.L.Unlock()
return nil
}
func (s *loopbackNatsSubscription) run() {