working stream implementations for core.async channels and BlockingQueues