Steward can miss asyncInbound frames

[joonas-fi]

asyncInbound is an unbuffered channel, and this line is using non-blocking send:

znp-go/processor.go

Line 179 in 69131cf

case znp.asyncInbound <- cp:

This looked dangerous to me, so I added error logging to the default: case (failed to send), and sure enough, I was actually running into this. If consumer (let's say Steward) is processing an existing message and therefore is not waiting to receive, inbound frames are silently dropped on the floor.

Easy solution is to make this channel buffered, perhaps 10 or 100 frames.