Use `fs2.concurrent.Channel` instead of `Queue`

[Baccata]

For possibly more graceful shutdown