public final class ServerCalls extends Object
Modifier and Type | Method and Description |
---|---|
static <I,O> io.grpc.stub.StreamObserver<I> |
manyToMany(io.grpc.stub.StreamObserver<O> response,
String compression,
BiConsumer<io.vertx.core.streams.ReadStream<I>,io.vertx.core.streams.WriteStream<O>> delegate) |
static <I,O> io.grpc.stub.StreamObserver<I> |
manyToOne(io.grpc.stub.StreamObserver<O> response,
String compression,
Function<io.vertx.core.streams.ReadStream<I>,io.vertx.core.Future<O>> delegate) |
static <I,O> void |
oneToMany(I request,
io.grpc.stub.StreamObserver<O> response,
String compression,
BiConsumer<I,io.vertx.core.streams.WriteStream<O>> delegate) |
static <I,O> void |
oneToOne(I request,
io.grpc.stub.StreamObserver<O> response,
String compression,
Function<I,io.vertx.core.Future<O>> delegate) |
public static <I,O> void oneToOne(I request, io.grpc.stub.StreamObserver<O> response, String compression, Function<I,io.vertx.core.Future<O>> delegate)
public static <I,O> void oneToMany(I request, io.grpc.stub.StreamObserver<O> response, String compression, BiConsumer<I,io.vertx.core.streams.WriteStream<O>> delegate)
public static <I,O> io.grpc.stub.StreamObserver<I> manyToOne(io.grpc.stub.StreamObserver<O> response, String compression, Function<io.vertx.core.streams.ReadStream<I>,io.vertx.core.Future<O>> delegate)
public static <I,O> io.grpc.stub.StreamObserver<I> manyToMany(io.grpc.stub.StreamObserver<O> response, String compression, BiConsumer<io.vertx.core.streams.ReadStream<I>,io.vertx.core.streams.WriteStream<O>> delegate)
Copyright © 2022 Eclipse. All rights reserved.