diff --git a/src/main/java/org/redkale/net/client/Client.java b/src/main/java/org/redkale/net/client/Client.java index ecb63d926..bd4b0d5c3 100644 --- a/src/main/java/org/redkale/net/client/Client.java +++ b/src/main/java/org/redkale/net/client/Client.java @@ -265,63 +265,20 @@ public abstract class Client, R extends ClientR return sendAsync(getAddress(request), (Function) null, request); } - public final CompletableFuture

[] sendAsync(R... requests) { - return sendAsync(getAddress(requests[0]), (Function) null, requests); - } - public final CompletableFuture sendAsync(Function respTransfer, R request) { return sendAsync(getAddress(request), respTransfer, request); } - public final CompletableFuture[] sendAsync(Function respTransfer, R... requests) { - return sendAsync(getAddress(requests[0]), respTransfer, requests); - } - public final CompletableFuture

sendAsync(SocketAddress addr, R request) { return sendAsync(addr, (Function) null, request); } - public final CompletableFuture

[] sendAsync(SocketAddress addr, R... requests) { - return sendAsync(addr, (Function) null, requests); - } - public final CompletableFuture sendAsync(SocketAddress addr, Function respTransfer, R request) { request.traceid = Traces.computeIfAbsent(request.traceid, Traces.currentTraceid()); request.computeWorkThreadIfAbsent(); return connect(request.workThread, addr).thenCompose(conn -> writeChannel(conn, respTransfer, request)); } - public final CompletableFuture[] sendAsync(SocketAddress addr, Function respTransfer, R... requests) { - String traceid = Traces.computeIfAbsent(requests[0].traceid, Traces.currentTraceid()); - ClientFuture[] respFutures = new ClientFuture[requests.length]; - for (int i = 0; i < respFutures.length; i++) { - R request = requests[i]; - request.traceid = traceid; - request.computeWorkThreadIfAbsent(); - respFutures[i] = createClientFuture(null, requests[i]); - } - connect(requests[0].workThread, addr).whenComplete((conn, t) -> { - if (t != null) { - for (ClientFuture f : respFutures) { - f.completeExceptionally(t); - } - } else { - CompletableFuture[] fs = writeChannel(conn, respTransfer, requests); - for (int i = 0; i < respFutures.length; i++) { - final int index = i; - fs[index].whenComplete((v, e) -> { - if (e != null) { - respFutures[index].completeExceptionally(e); - } else { - respFutures[index].complete(v); - } - }); - } - } - }); - return respFutures; - } - protected CompletableFuture

writeChannel(ClientConnection conn, R request) { return conn.writeChannel(request); }