#include <transport_stream_receiver_impl.h>

Inheritance diagram for grpc_binder::TransportStreamReceiverImpl:

Public Member Functions
void	CancelStream (StreamIdentifier id) override

void	NotifyRecvInitialMetadata (StreamIdentifier id, absl::StatusOr< Metadata > initial_metadata) override

void	NotifyRecvMessage (StreamIdentifier id, absl::StatusOr< std::string > message) override

void	NotifyRecvTrailingMetadata (StreamIdentifier id, absl::StatusOr< Metadata > trailing_metadata, int status) override

void	RegisterRecvInitialMetadata (StreamIdentifier id, InitialMetadataCallbackType cb) override

void	RegisterRecvMessage (StreamIdentifier id, MessageDataCallbackType cb) override

void	RegisterRecvTrailingMetadata (StreamIdentifier id, TrailingMetadataCallbackType cb) override

	TransportStreamReceiverImpl (bool is_client, std::function< void()> accept_stream_callback=nullptr)

Public Member Functions inherited from grpc_binder::TransportStreamReceiver
virtual	~TransportStreamReceiver ()=default

Private Member Functions
std::map< StreamIdentifier, std::queue< absl::StatusOr< Metadata > > > pending_initial_metadata_	ABSL_GUARDED_BY (m_)

std::map< StreamIdentifier, std::queue< absl::StatusOr< std::string > > > pending_message_	ABSL_GUARDED_BY (m_)

std::map< StreamIdentifier, std::queue< std::pair< absl::StatusOr< Metadata >, int > > > pending_trailing_metadata_	ABSL_GUARDED_BY (m_)

std::set< StreamIdentifier > trailing_metadata_recvd_	ABSL_GUARDED_BY (m_)

void	CancelInitialMetadataCallback (StreamIdentifier id, absl::Status error)

void	CancelMessageCallback (StreamIdentifier id, absl::Status error)

void	CancelTrailingMetadataCallback (StreamIdentifier id, absl::Status error)

void	OnRecvTrailingMetadata (StreamIdentifier id)

Private Attributes
std::function< void()>	accept_stream_callback_

std::map< StreamIdentifier, InitialMetadataCallbackType >	initial_metadata_cbs_

bool	is_client_

grpc_core::Mutex	m_

std::map< StreamIdentifier, MessageDataCallbackType >	message_cbs_

std::map< StreamIdentifier, TrailingMetadataCallbackType >	trailing_metadata_cbs_

Additional Inherited Members
Public Types inherited from grpc_binder::TransportStreamReceiver
using	InitialMetadataCallbackType = std::function< void(absl::StatusOr< Metadata >)>

using	MessageDataCallbackType = std::function< void(absl::StatusOr< std::string >)>

using	TrailingMetadataCallbackType = std::function< void(absl::StatusOr< Metadata >, int)>

Static Public Attributes inherited from grpc_binder::TransportStreamReceiver
static const absl::string_view	kGrpcBinderTransportCancelledGracefully

Detailed Description

Definition at line 33 of file transport_stream_receiver_impl.h.

Constructor & Destructor Documentation

◆ TransportStreamReceiverImpl()

grpc_binder::TransportStreamReceiverImpl::TransportStreamReceiverImpl	(	bool	is_client,
		std::function< void()>	accept_stream_callback = `nullptr`
	)

inlineexplicit

Definition at line 35 of file transport_stream_receiver_impl.h.

Member Function Documentation

◆ ABSL_GUARDED_BY() [1/4]

std::map<StreamIdentifier, std::queue<absl::StatusOr<Metadata> > > pending_initial_metadata_ grpc_binder::TransportStreamReceiverImpl::ABSL_GUARDED_BY ( m_ )

private

◆ ABSL_GUARDED_BY() [2/4]

std::map<StreamIdentifier, std::queue<absl::StatusOr<std::string> > > pending_message_ grpc_binder::TransportStreamReceiverImpl::ABSL_GUARDED_BY ( m_ )

private

◆ ABSL_GUARDED_BY() [3/4]

std::map<StreamIdentifier, std::queue<std::pair<absl::StatusOr<Metadata>, int> > > pending_trailing_metadata_ grpc_binder::TransportStreamReceiverImpl::ABSL_GUARDED_BY ( m_ )

private

◆ ABSL_GUARDED_BY() [4/4]

std::set<StreamIdentifier> trailing_metadata_recvd_ grpc_binder::TransportStreamReceiverImpl::ABSL_GUARDED_BY ( m_ )

private

◆ CancelInitialMetadataCallback()

void grpc_binder::TransportStreamReceiverImpl::CancelInitialMetadataCallback	(	StreamIdentifier	id,
		absl::Status	error
	)

private

Definition at line 183 of file transport_stream_receiver_impl.cc.

◆ CancelMessageCallback()

void grpc_binder::TransportStreamReceiverImpl::CancelMessageCallback	(	StreamIdentifier	id,
		absl::Status	error
	)

private

Definition at line 199 of file transport_stream_receiver_impl.cc.

◆ CancelStream()

void grpc_binder::TransportStreamReceiverImpl::CancelStream ( StreamIdentifier id )

overridevirtual

Implements grpc_binder::TransportStreamReceiver.

Definition at line 243 of file transport_stream_receiver_impl.cc.

◆ CancelTrailingMetadataCallback()

void grpc_binder::TransportStreamReceiverImpl::CancelTrailingMetadataCallback	(	StreamIdentifier	id,
		absl::Status	error
	)

private

Definition at line 215 of file transport_stream_receiver_impl.cc.

◆ NotifyRecvInitialMetadata()

void grpc_binder::TransportStreamReceiverImpl::NotifyRecvInitialMetadata	(	StreamIdentifier	id,
		absl::StatusOr< Metadata >	initial_metadata
	)

overridevirtual

Implements grpc_binder::TransportStreamReceiver.

Definition at line 119 of file transport_stream_receiver_impl.cc.

◆ NotifyRecvMessage()

void grpc_binder::TransportStreamReceiverImpl::NotifyRecvMessage	(	StreamIdentifier	id,
		absl::StatusOr< std::string >	message
	)

overridevirtual

Implements grpc_binder::TransportStreamReceiver.

Definition at line 140 of file transport_stream_receiver_impl.cc.

◆ NotifyRecvTrailingMetadata()

void grpc_binder::TransportStreamReceiverImpl::NotifyRecvTrailingMetadata	(	StreamIdentifier	id,
		absl::StatusOr< Metadata >	trailing_metadata,
		int	status
	)