#include <async_stream.h>

Public Member Functions
template<class W >
	ClientAsyncReader (ChannelInterface channel, CompletionQueue cq, const RpcMethod &method, ClientContext context, const W &request, void tag)
	Create a stream and write the first request out. More...

void	ReadInitialMetadata (void *tag) GRPC_OVERRIDE
	Request notification of the reading of the initial metadata. More...

void	Read (R msg, void tag) GRPC_OVERRIDE
	Read a message of type R into msg. More...

void	Finish (Status status, void tag) GRPC_OVERRIDE
	Indicate that the stream is to be finished and request notification Should not be used concurrently with other operations. More...

Public Member Functions inherited from grpc::ClientAsyncStreamingInterface
virtual	~ClientAsyncStreamingInterface ()

Public Member Functions inherited from grpc::AsyncReaderInterface< R >
virtual	~AsyncReaderInterface ()

Constructor & Destructor Documentation

template<class R >

template<class W >

grpc::ClientAsyncReader< R >::ClientAsyncReader	(	ChannelInterface *	channel,
		CompletionQueue *	cq,
		const RpcMethod &	method,
		ClientContext *	context,
		const W &	request,
		void *	tag
	)

inline

Create a stream and write the first request out.

Member Function Documentation

template<class R >

void grpc::ClientAsyncReader< R >::Finish	(	Status *	status,
		void *	tag
	)

inlinevirtual

Indicate that the stream is to be finished and request notification Should not be used concurrently with other operations.

Parameters

[out]	status	To be updated with the operation status.
[in]	tag	Tag identifying this request.

Implements grpc::ClientAsyncStreamingInterface.

template<class R >

void grpc::ClientAsyncReader< R >::Read	(	R *	msg,
		void *	tag
	)

inlinevirtual

Read a message of type R into msg.

Completion will be notified by tag on the associated completion queue. This is thread-safe with respect to Write or WritesDone methods. It should not be called concurrently with other streaming APIs on the same stream. It is not meaningful to call it concurrently with another Read on the same stream since reads on the same stream are delivered in order.

Parameters

[out]	msg	Where to eventually store the read message.
[in]	tag	The tag identifying the operation.

Implements grpc::AsyncReaderInterface< R >.

template<class R >

void grpc::ClientAsyncReader< R >::ReadInitialMetadata ( void * tag )

inlinevirtual

Request notification of the reading of the initial metadata.

Completion will be notified by tag on the associated completion queue. This call is optional, but if it is used, it cannot be used concurrently with or after the Read method.

Parameters

[in] tag Tag identifying this request.

Implements grpc::ClientAsyncStreamingInterface.

The documentation for this class was generated from the following file:

include/grpc++/impl/codegen/async_stream.h

Public Member Functions

Constructor & Destructor Documentation

Member Function Documentation