Fix end of stream detection during rejoin bug introduced by the previous refactoring.
Fix end of stream detection during rejoin bug introduced by the previous
refactoring.

zuowang/voltdb,creative-quant/voltdb,creative-quant/voltdb,simonzhangsm/voltdb,VoltDB/voltdb,simonzhangsm/voltdb,creative-quant/voltdb,VoltDB/voltdb,migue/voltdb,creative-quant/voltdb,migue/voltdb,zuowang/voltdb,migue/voltdb,VoltDB/voltdb,deerwalk/voltdb,creative-quant/voltdb,simonzhangsm/voltdb,paulmartel/voltdb,kumarrus/voltdb,paulmartel/voltdb,migue/voltdb,deerwalk/voltdb,deerwalk/voltdb,VoltDB/voltdb,deerwalk/voltdb,ingted/voltdb,flybird119/voltdb,ingted/voltdb,paulmartel/voltdb,kumarrus/voltdb,paulmartel/voltdb,ingted/voltdb,ingted/voltdb,zuowang/voltdb,creative-quant/voltdb,flybird119/voltdb,deerwalk/voltdb,kumarrus/voltdb,migue/voltdb,flybird119/voltdb,simonzhangsm/voltdb,zuowang/voltdb,wolffcm/voltdb,migue/voltdb,VoltDB/voltdb,zuowang/voltdb,wolffcm/voltdb,VoltDB/voltdb,migue/voltdb,zuowang/voltdb,zuowang/voltdb,ingted/voltdb,paulmartel/voltdb,flybird119/voltdb,flybird119/voltdb,simonzhangsm/voltdb,wolffcm/voltdb,wolffcm/voltdb,wolffcm/voltdb,flybird119/voltdb,deerwalk/voltdb,flybird119/voltdb,ingted/voltdb,deerwalk/voltdb,wolffcm/voltdb,wolffcm/voltdb,simonzhangsm/voltdb,flybird119/voltdb,kumarrus/voltdb,simonzhangsm/voltdb,ingted/voltdb,simonzhangsm/voltdb,VoltDB/voltdb,migue/voltdb,zuowang/voltdb,creative-quant/voltdb,paulmartel/voltdb,ingted/voltdb,deerwalk/voltdb,creative-quant/voltdb,wolffcm/voltdb,kumarrus/voltdb,paulmartel/voltdb,kumarrus/voltdb,paulmartel/voltdb,kumarrus/voltdb,kumarrus/voltdb