File tree Expand file tree Collapse file tree 2 files changed +0
-23
lines changed
vertx-sql-client/src/main/java/io/vertx/sqlclient/internal/command Expand file tree Collapse file tree 2 files changed +0
-23
lines changed Original file line number Diff line number Diff line change 1717
1818package io .vertx .sqlclient .internal .command ;
1919
20- import io .vertx .core .AsyncResult ;
21- import io .vertx .core .Completable ;
22- import io .vertx .core .Future ;
23- import io .vertx .core .Handler ;
24-
2520/**
2621 * @author <a href="mailto:[email protected] ">Julien Viet</a> 2722 */
2823
2924public abstract class CommandBase <R > {
30-
31- public Completable <R > handler ;
32-
33- public final void fail (Throwable err ) {
34- complete (Future .failedFuture (err ));
35- }
36-
37- public final void fail (String failureMsg ) {
38- complete (Future .failedFuture (failureMsg ));
39- }
40-
41- public final void complete (AsyncResult <R > resp ) {
42- if (handler != null ) {
43- handler .complete (resp .result (), resp .cause ());
44- }
45- }
4625}
Original file line number Diff line number Diff line change @@ -46,8 +46,6 @@ public AsyncResult<R> toAsyncResult() {
4646 public final void fire () {
4747 if (handler != null ) {
4848 handler .complete (res .result (), res .cause ());
49- } else if (cmd .handler != null ) {
50- cmd .handler .complete (res .result (), res .cause ());
5149 }
5250 }
5351}
You can’t perform that action at this time.
0 commit comments