TriggeredInputStream for non-blocking consumption of body