Async server-side API for doing server streaming RPCs, where the outgoing message stream from the server has messages of type W. More...

#include <async_stream.h>

Public Member Functions
	ServerAsyncWriter (ServerContext *ctx)

void	SendInitialMetadata (void *tag) override
	See ServerAsyncStreamingInterface::SendInitialMetadata for semantics. More...

void	Write (const W &msg, void *tag) override
	Request the writing of msg with identifying tag tag. More...

void	Write (const W &msg, WriteOptions options, void *tag) override
	Request the writing of msg using WriteOptions options with identifying tag tag. More...

void	WriteAndFinish (const W &msg, WriteOptions options, const Status &status, void *tag) override
	See the ServerAsyncWriterInterface.WriteAndFinish method for semantics. More...

void	Finish (const Status &status, void *tag) override
	See the ServerAsyncWriterInterface.Finish method for semantics. More...

Public Member Functions inherited from grpc::internal::ServerAsyncStreamingInterface
virtual	~ServerAsyncStreamingInterface ()

Public Member Functions inherited from grpc::internal::AsyncWriterInterface< W >
virtual	~AsyncWriterInterface ()

void	WriteLast (const W &msg, WriteOptions options, void *tag)
	Request the writing of msg and coalesce it with the writing of trailing metadata, using WriteOptions options with identifying tag tag. More...

Detailed Description

template<class W>
class grpc::ServerAsyncWriter< W >

Async server-side API for doing server streaming RPCs, where the outgoing message stream from the server has messages of type W.

Constructor & Destructor Documentation

◆ ServerAsyncWriter()

template<class W >

grpc::ServerAsyncWriter< W >::ServerAsyncWriter ( ServerContext * ctx )

inlineexplicit

Member Function Documentation

◆ Finish()

template<class W >

void grpc::ServerAsyncWriter< W >::Finish	(	const Status &	status,
		void *	tag
	)

inlineoverridevirtual

See the ServerAsyncWriterInterface.Finish method for semantics.

Implicit input parameter:

the ServerContext associated with this call is used for sending trailing (and initial if not already sent) metadata to the client.

Note: there are no restrictions are the code of status,it may be non-OK

Implements grpc::ServerAsyncWriterInterface< W >.

◆ SendInitialMetadata()

template<class W >

void grpc::ServerAsyncWriter< W >::SendInitialMetadata ( void * tag )

inlineoverridevirtual

See ServerAsyncStreamingInterface::SendInitialMetadata for semantics.

Implicit input parameter:

The initial metadata that will be sent to the client from this op will be taken from the ServerContext associated with the call.

Parameters

[in] tag Tag identifying this request.

Implements grpc::internal::ServerAsyncStreamingInterface.

◆ Write() [1/2]

template<class W >

void grpc::ServerAsyncWriter< W >::Write	(	const W &	msg,
		void *	tag
	)

inlineoverridevirtual

Request the writing of msg with identifying tag tag.

Only one write may be outstanding at any given time. This means that after calling Write, one must wait to receive tag from the completion queue BEFORE calling Write again. This is thread-safe with respect to AsyncReaderInterface::Read

Parameters

[in]	msg	The message to be written.
[in]	tag	The tag identifying the operation.

Implements grpc::internal::AsyncWriterInterface< W >.

◆ Write() [2/2]

template<class W >

void grpc::ServerAsyncWriter< W >::Write	(	const W &	msg,
		WriteOptions	options,
		void *	tag
	)

inlineoverridevirtual

Request the writing of msg using WriteOptions options with identifying tag tag.

Only one write may be outstanding at any given time. This means that after calling Write, one must wait to receive tag from the completion queue BEFORE calling Write again. WriteOptions options is used to set the write options of this message. This is thread-safe with respect to AsyncReaderInterface::Read

Parameters

[in]	msg	The message to be written.
[in]	options	The WriteOptions to be used to write this message.
[in]	tag	The tag identifying the operation.

Implements grpc::internal::AsyncWriterInterface< W >.

◆ WriteAndFinish()

template<class W >

void grpc::ServerAsyncWriter< W >::WriteAndFinish	(	const W &	msg,
		WriteOptions	options,
		const Status &	status,
		void *	tag
	)

inlineoverridevirtual

See the ServerAsyncWriterInterface.WriteAndFinish method for semantics.

Implicit input parameter:

the ServerContext associated with this call is used for sending trailing (and initial) metadata to the client.

Note: status must have an OK code.

Implements grpc::ServerAsyncWriterInterface< W >.

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

include/grpcpp/impl/codegen/async_stream.h

Public Member Functions

Detailed Description

template<class W> class grpc::ServerAsyncWriter< W >

Constructor & Destructor Documentation

◆ ServerAsyncWriter()

Member Function Documentation

◆ Finish()

◆ SendInitialMetadata()

◆ Write() [1/2]

◆ Write() [2/2]

◆ WriteAndFinish()

template<class W>
class grpc::ServerAsyncWriter< W >