public void launch ( Object arg ) { ReconnectableMap . INSTANCE . dismiss ( key ) ; out . put ( "restore" , true ) ; out . put ( "arg" , arg ) ; launches . onNext ( arg ) ; }
Launches an observable providing an argument . Dismisses the previous observable instance if it is not completed yet .