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