Add backpressure to InMemoryExchange