public final class ClientCalls extends Object
Modifier and Type | Method and Description |
---|---|
static <I,O> ReadStream<O> |
manyToMany(io.vertx.core.impl.ContextInternal ctx,
Handler<WriteStream<I>> requestHandler,
java.util.function.Function<io.grpc.stub.StreamObserver<O>,io.grpc.stub.StreamObserver<I>> delegate) |
static <I,O> Future<O> |
manyToOne(io.vertx.core.impl.ContextInternal ctx,
Handler<WriteStream<I>> requestHandler,
java.util.function.Function<io.grpc.stub.StreamObserver<O>,io.grpc.stub.StreamObserver<I>> delegate) |
static <I,O> ReadStream<O> |
oneToMany(io.vertx.core.impl.ContextInternal ctx,
I request,
java.util.function.BiConsumer<I,io.grpc.stub.StreamObserver<O>> delegate) |
static <I,O> Future<O> |
oneToOne(io.vertx.core.impl.ContextInternal ctx,
I request,
java.util.function.BiConsumer<I,io.grpc.stub.StreamObserver<O>> delegate) |
public static <I,O> Future<O> oneToOne(io.vertx.core.impl.ContextInternal ctx, I request, java.util.function.BiConsumer<I,io.grpc.stub.StreamObserver<O>> delegate)
public static <I,O> ReadStream<O> oneToMany(io.vertx.core.impl.ContextInternal ctx, I request, java.util.function.BiConsumer<I,io.grpc.stub.StreamObserver<O>> delegate)
public static <I,O> Future<O> manyToOne(io.vertx.core.impl.ContextInternal ctx, Handler<WriteStream<I>> requestHandler, java.util.function.Function<io.grpc.stub.StreamObserver<O>,io.grpc.stub.StreamObserver<I>> delegate)
public static <I,O> ReadStream<O> manyToMany(io.vertx.core.impl.ContextInternal ctx, Handler<WriteStream<I>> requestHandler, java.util.function.Function<io.grpc.stub.StreamObserver<O>,io.grpc.stub.StreamObserver<I>> delegate)
Copyright © 2023 Eclipse. All rights reserved.