We can check the second optional value from the channel receive:

```go
case message, open := <-consumer.in:
    // ... handle when !open
    if !open || err != nil {
```

how does that seem?