org.springframework.cloud.function.grpc

Class MessagingServiceGrpc.MessagingServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<MessagingServiceGrpc.MessagingServiceStub>

org.springframework.cloud.function.grpc.MessagingServiceGrpc.MessagingServiceStub

Enclosing class:

MessagingServiceGrpc

public static final class MessagingServiceGrpc.MessagingServiceStub
extends io.grpc.stub.AbstractStub<MessagingServiceGrpc.MessagingServiceStub>

Method Summary

Modifier and Type	Method and Description
io.grpc.stub.StreamObserver<GrpcMessage>	biStream(io.grpc.stub.StreamObserver<GrpcMessage> responseObserver)
protected MessagingServiceGrpc.MessagingServiceStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
io.grpc.stub.StreamObserver<GrpcMessage>	clientStream(io.grpc.stub.StreamObserver<GrpcMessage> responseObserver)
void	requestReply(GrpcMessage request, io.grpc.stub.StreamObserver<GrpcMessage> responseObserver)
void	serverStream(GrpcMessage request, io.grpc.stub.StreamObserver<GrpcMessage> responseObserver)

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady

Methods inherited from class java.lang.Object

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

Method Detail

build

protected MessagingServiceGrpc.MessagingServiceStub build(io.grpc.Channel channel,
                                                          io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<MessagingServiceGrpc.MessagingServiceStub>

biStream

public io.grpc.stub.StreamObserver<GrpcMessage> biStream(io.grpc.stub.StreamObserver<GrpcMessage> responseObserver)

clientStream

public io.grpc.stub.StreamObserver<GrpcMessage> clientStream(io.grpc.stub.StreamObserver<GrpcMessage> responseObserver)

serverStream

public void serverStream(GrpcMessage request,
                         io.grpc.stub.StreamObserver<GrpcMessage> responseObserver)

requestReply

public void requestReply(GrpcMessage request,
                         io.grpc.stub.StreamObserver<GrpcMessage> responseObserver)