The StreamInputHandler on_received_messages function has return value, but no one will handle the return value. I think it is better to make it possible for handling the failure