Pass the receive callback to streams.
Start trying to deal with flow control.