Backpressure support

We should set a hwm of 2. This allows one batch us to buffer a single batch before write starts returning false and backpressure kicks in when piping.