Moved futureconsumer away from using queues to raw pipes