Added the dispose consumer back.

EndOfStream exception thrown to indicates connection closure.