Emit end event after the disconnect frame is processed or when the input stream has ended without pending disconnect
Don't send error frame to subscriber when they disconnect with pending receives. Cleanup pending subscription messages when consumer unsubscribes or disconnects
Send error frame if the ACK/NACK frame is received before the message is completely sent