fix(stream): make consumer decrement pending number when message is acknowledged.

fix(stream): make consumer decrement pending number when message is acknowledged. #57