19
19
import com .ibm .cloud .sdk .core .http .ResponseConverter ;
20
20
import com .ibm .cloud .sdk .core .http .ServiceCall ;
21
21
import com .ibm .cloud .sdk .core .http .ServiceCallback ;
22
- import com .ibm .cloud .sdk .core .http .ServiceCallbackWithDetails ;
23
22
import com .ibm .cloud .sdk .core .service .exception .BadRequestException ;
24
23
import com .ibm .cloud .sdk .core .service .exception .ConflictException ;
25
24
import com .ibm .cloud .sdk .core .service .exception .ForbiddenException ;
@@ -480,47 +479,18 @@ public ServiceCall<T> addHeader(String name, String value) {
480
479
}
481
480
482
481
@ Override
483
- public T execute () {
482
+ public com . ibm . cloud . sdk . core . http . Response < T > execute () {
484
483
try {
485
484
Response response = call .execute ();
486
- return processServiceCall (converter , response );
487
- } catch (IOException e ) {
488
- throw new RuntimeException (e );
489
- }
490
- }
491
-
492
- @ Override
493
- public com .ibm .cloud .sdk .core .http .Response <T > executeWithDetails () throws RuntimeException {
494
- try {
495
- Response httpResponse = call .execute ();
496
- T responseModel = processServiceCall (converter , httpResponse );
497
- return new com .ibm .cloud .sdk .core .http .Response <>(responseModel , httpResponse );
485
+ T responseModel = processServiceCall (converter , response );
486
+ return new com .ibm .cloud .sdk .core .http .Response <>(responseModel , response );
498
487
} catch (IOException e ) {
499
488
throw new RuntimeException (e );
500
489
}
501
490
}
502
491
503
492
@ Override
504
493
public void enqueue (final ServiceCallback <? super T > callback ) {
505
- call .enqueue (new Callback () {
506
- @ Override
507
- public void onFailure (Call call , IOException e ) {
508
- callback .onFailure (e );
509
- }
510
-
511
- @ Override
512
- public void onResponse (Call call , Response response ) {
513
- try {
514
- callback .onResponse (processServiceCall (converter , response ));
515
- } catch (Exception e ) {
516
- callback .onFailure (e );
517
- }
518
- }
519
- });
520
- }
521
-
522
- @ Override
523
- public void enqueueWithDetails (final ServiceCallbackWithDetails <T > callback ) {
524
494
call .enqueue (new Callback () {
525
495
@ Override
526
496
public void onFailure (Call call , IOException e ) {
@@ -540,24 +510,13 @@ public void onResponse(Call call, Response response) {
540
510
}
541
511
542
512
@ Override
543
- public Single <T > reactiveRequest () {
544
- return Single .fromCallable (new Callable <T >() {
545
- @ Override
546
- public T call () throws Exception {
547
- Response response = call .execute ();
548
- return processServiceCall (converter , response );
549
- }
550
- });
551
- }
552
-
553
- @ Override
554
- public Single <com .ibm .cloud .sdk .core .http .Response <T >> reactiveRequestWithDetails () {
513
+ public Single <com .ibm .cloud .sdk .core .http .Response <T >> reactiveRequest () {
555
514
return Single .fromCallable (new Callable <com .ibm .cloud .sdk .core .http .Response <T >>() {
556
515
@ Override
557
516
public com .ibm .cloud .sdk .core .http .Response <T > call () throws Exception {
558
- Response httpResponse = call .execute ();
559
- T responseModel = processServiceCall (converter , httpResponse );
560
- return new com .ibm .cloud .sdk .core .http .Response <>(responseModel , httpResponse );
517
+ Response response = call .execute ();
518
+ T responseModel = processServiceCall (converter , response );
519
+ return new com .ibm .cloud .sdk .core .http .Response <>(responseModel , response );
561
520
}
562
521
});
563
522
}
0 commit comments