in singe table subscription, after consume all data, the next call to consume crash both client and server.

this commit fix the issue.