JVMCBC-28: Streaming handlers do not respect next observable.

Change-Id: I38dbc3face79a4386daa84e0036bc5dc1156037c