io.vertx.grpc.stub

Class ClientCalls

java.lang.Object

io.vertx.grpc.stub.ClientCalls

public final class ClientCalls
extends Object

Author:

Rogelio Orts, Eduard Català

Method Summary

Modifier and Type	Method and Description
static <I,O> ReadStream<O>	manyToMany(ContextInternal ctx, Handler<WriteStream<I>> requestHandler, Function<io.grpc.stub.StreamObserver<O>,io.grpc.stub.StreamObserver<I>> delegate)
static <I,O> Future<O>	manyToOne(ContextInternal ctx, Handler<WriteStream<I>> requestHandler, Function<io.grpc.stub.StreamObserver<O>,io.grpc.stub.StreamObserver<I>> delegate)
static <I,O> ReadStream<O>	oneToMany(ContextInternal ctx, I request, BiConsumer<I,io.grpc.stub.StreamObserver<O>> delegate)
static <I,O> Future<O>	oneToOne(ContextInternal ctx, I request, BiConsumer<I,io.grpc.stub.StreamObserver<O>> delegate)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

oneToOne

public static <I,O> Future<O> oneToOne(ContextInternal ctx,
                                       I request,
                                       BiConsumer<I,io.grpc.stub.StreamObserver<O>> delegate)

oneToMany

public static <I,O> ReadStream<O> oneToMany(ContextInternal ctx,
                                            I request,
                                            BiConsumer<I,io.grpc.stub.StreamObserver<O>> delegate)

manyToOne

public static <I,O> Future<O> manyToOne(ContextInternal ctx,
                                        Handler<WriteStream<I>> requestHandler,
                                        Function<io.grpc.stub.StreamObserver<O>,io.grpc.stub.StreamObserver<I>> delegate)

manyToMany

public static <I,O> ReadStream<O> manyToMany(ContextInternal ctx,
                                             Handler<WriteStream<I>> requestHandler,
                                             Function<io.grpc.stub.StreamObserver<O>,io.grpc.stub.StreamObserver<I>> delegate)