private Observable < ChatResult > handleMessageError ( MessageProcessor mp , Throwable t ) { return persistenceController . updateStoreForSentError ( mp . getConversationId ( ) , mp . getTempId ( ) , mp . getSender ( ) ) . map ( success -> new ChatResult ( false , new ChatResult . Error ( 0 , t ) ) ) ; }
Handle failure when sent message .