public Observable < RestApiResponse > execute ( ) { return deferAndWatch ( new Func1 < Subscriber , Observable < ? extends RestApiResponse > > ( ) { @ Override public Observable < ? extends RestApiResponse > call ( Subscriber subscriber ) { RestApiRequest apiRequest = asRequest ( ) ; LOGGER . debug ( "Executing Cluster API request {} on {}" , apiRequest . method ( ) , apiRequest . pathWithParameters ( ) ) ; apiRequest . subscriber ( subscriber ) ; return core . send ( apiRequest ) ; } } ) ; }
Executes the API request in an asynchronous fashion .