ugrpc::server::BidirectionalStream< Request, Response > Class Template Reference

Table of Contents

• Public Member Functions
• Additional Inherited Members
• Detailed Description
• Constructor & Destructor Documentation
• BidirectionalStream()
• ~BidirectionalStream()
• Member Function Documentation
• Finish()
• FinishWithError()
• IsFinished()
• Read()
• Write()
• WriteAndFinish()

Controls a request stream -> response stream RPC. More...

#include <userver/ugrpc/server/rpc.hpp>

Inheritance diagram for ugrpc::server::BidirectionalStream< Request, Response >:

Collaboration diagram for ugrpc::server::BidirectionalStream< Request, Response >:

Public Member Functions
bool	Read (Request &request)
	Await and read the next incoming message.
void	Write (const Response &response)
	Write the next outgoing message.
void	Finish ()
	Complete the RPC successfully.
void	FinishWithError (const grpc::Status &status) override
	Complete the RPC with an error.
void	WriteAndFinish (const Response &response)
	Equivalent to Write + Finish
	BidirectionalStream (impl::CallParams &&call_params, impl::RawReaderWriter< Request, Response > &stream)
	For internal use only.
	BidirectionalStream (const BidirectionalStream &)=delete
	BidirectionalStream (BidirectionalStream &&)=delete
bool	IsFinished () const override
Public Member Functions inherited from ugrpc::server::CallAnyBase
	CallAnyBase (impl::CallParams &&params)
grpc::ServerContext &	GetContext ()
std::string_view	GetCallName () const
	Name of the call. Consists of service and method names.
tracing::Span &	GetSpan ()

Additional Inherited Members
Protected Member Functions inherited from ugrpc::server::CallAnyBase
ugrpc::impl::RpcStatisticsScope &	Statistics ()
logging::LoggerRef	AccessTskvLogger ()
void	LogFinish (grpc::Status status) const

Detailed Description

template<typename Request, typename Response>
class ugrpc::server::BidirectionalStream< Request, Response >

Controls a request stream -> response stream RPC.

This class is not thread-safe except for GetContext.

The RPC is cancelled on destruction unless the stream has been finished.

If any method throws, further methods must not be called on the same stream, except for GetContext.

Definition at line 226 of file rpc.hpp.

Constructor & Destructor Documentation

BidirectionalStream()

template<typename Request , typename Response >

ugrpc::server::BidirectionalStream< Request, Response >::BidirectionalStream	(	impl::CallParams &&	call_params,
		impl::RawReaderWriter< Request, Response > &	stream
	)

For internal use only.

Definition at line 449 of file rpc.hpp.

~BidirectionalStream()

template<typename Request , typename Response >

ugrpc::server::BidirectionalStream< Request, Response >::~BidirectionalStream

(

)

Definition at line 455 of file rpc.hpp.

Member Function Documentation

Finish()

template<typename Request , typename Response >

void ugrpc::server::BidirectionalStream< Request, Response >::Finish

(

)

Complete the RPC successfully.

Finish must not be called multiple times.

Exceptions

ugrpc::server::RpcError

on an RPC error

Definition at line 485 of file rpc.hpp.

FinishWithError()

template<typename Request , typename Response >

void ugrpc::server::BidirectionalStream< Request, Response >::FinishWithError ( const grpc::Status &  status )

overridevirtual

Complete the RPC with an error.

Finish must not be called multiple times.

Parameters

status

error details

Exceptions

ugrpc::server::RpcError

on an RPC error

Implements ugrpc::server::CallAnyBase.

Definition at line 497 of file rpc.hpp.

IsFinished()

template<typename Request , typename Response >

bool ugrpc::server::BidirectionalStream< Request, Response >::IsFinished ( ) const

overridevirtual

Implements ugrpc::server::CallAnyBase.

Definition at line 525 of file rpc.hpp.

Read()

template<typename Request , typename Response >

bool ugrpc::server::BidirectionalStream< Request, Response >::Read

(

Request &

request

)

Await and read the next incoming message.

Parameters

request

where to put the request on success

Returns

true on success, false on end-of-input

Exceptions

ugrpc::server::RpcError

on an RPC error

Definition at line 463 of file rpc.hpp.

Write()

template<typename Request , typename Response >

void ugrpc::server::BidirectionalStream< Request, Response >::Write

(

const Response &

response

)

Write the next outgoing message.

Parameters

response

the next message to write

Exceptions

ugrpc::server::RpcError

on an RPC error

Definition at line 475 of file rpc.hpp.

WriteAndFinish()

template<typename Request , typename Response >

void ugrpc::server::BidirectionalStream< Request, Response >::WriteAndFinish

(

const Response &

response

)

Equivalent to Write + Finish

This call saves one round-trip, compared to separate Write and Finish.

Finish must not be called multiple times.

Parameters

response

the final response message

Exceptions

ugrpc::server::RpcError

on an RPC error

Definition at line 510 of file rpc.hpp.

---

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

• userver/ugrpc/server/rpc.hpp