Module io.inverno.mod.grpc.client

Package io.inverno.mod.grpc.client

Interface GrpcRequest.Streaming<A extends com.google.protobuf.Message>

Type Parameters:

A - The request message type

All Superinterfaces:

GrpcBaseRequest, GrpcRequest<A>

Enclosing interface:

GrpcRequest<A extends com.google.protobuf.Message>

public static interface GrpcRequest.Streaming<A extends com.google.protobuf.Message>
extends GrpcRequest<A>

Represents a streaming (stream of messages) request.

Since:

1.9

Author:

Jeremy Kuhn

Nested Class Summary

Nested classes/interfaces inherited from interface io.inverno.mod.grpc.client.GrpcRequest

GrpcRequest.Streaming<A extends com.google.protobuf.Message>, GrpcRequest.Unary<A extends com.google.protobuf.Message>

Method Summary

Modifier and Type	Method	Description
GrpcRequest.Streaming<A>	metadata(Consumer<GrpcOutboundRequestMetadata> metadataConfigurer)	Configures the gRPC request metadata to send in the request.
<T extends A> void	stream(Publisher<T> value)	Sets the request message publisher.

Methods inherited from interface io.inverno.mod.grpc.base.GrpcBaseRequest

getFullMethodName, getMethodName, getServiceName, metadata

Method Details

metadata

GrpcRequest.Streaming<A> metadata(Consumer<GrpcOutboundRequestMetadata> metadataConfigurer)
                           throws IllegalStateException

Description copied from interface: GrpcRequest

Configures the gRPC request metadata to send in the request.

Specified by:

metadata in interface GrpcRequest<A extends com.google.protobuf.Message>

Parameters:

metadataConfigurer - an outbound request metadata configurer

Returns:

the request

Throws:

IllegalStateException - if the request has already been sent to the endpoint

stream

<T extends A> void stream(Publisher<T> value)
                   throws IllegalStateException

Sets the request message publisher.

Type Parameters:

T - the request message type

Parameters:

value - the message publisher

Throws:

IllegalStateException - if messages were already sent to the endpoint