PushParser: data consumption fix.
BodyDecoder: honor connection-close as an end emitter