stress tests for incomplete stream consume
Summary:
Can repro crash if the stream is not fully consumed. A few ways to trigger:
1. don't consume anything from stream after starting `sink`.
2. only partially consume the stream
The following crash is unfixed:
- don't even call the `ClientSink.sink` method (see next diff)
Another way to trigger crash appears to be double calling the stream / sink. Want to isolate that a bit more.
Reviewed By: prakashgayasen
Differential Revision:
D85624468
fbshipit-source-id:
aba0b2335528bebcbf2692741d45db5f80204add