implement coro-based consumer-producer