I’m wondering: why allow the failure to sit here in a buffer? `onError` is supposed to be called out-of-band ASAP, and if someone does not want their stream to fail then they should better recover their Futures where they can.