Consumer output channel is closed twice on call for source/stop!

[hoplers]

One close on the consumer thread, on the finally clause of the consuming loop -

Second close on the thread calling to stop!

Could probably remove the sync one as the consumer wakeup always triggers a close on the finally clause