grpc.aio._interceptor._InterceptedStreamRequestMixin Class Reference

Inheritance diagram for grpc.aio._interceptor._InterceptedStreamRequestMixin:

Public Member Functions
None	done_writing (self)
None	write (self, RequestType request)

Private Member Functions
RequestIterableType	_init_stream_request_mixin (self, Optional[RequestIterableType] request_iterator)
def	_proxy_writes_as_request_iterator (self)
def	_write_to_iterator_queue_interruptible (self, RequestType request, InterceptedCall call)

Private Attributes
	_status_code_task
	_write_to_iterator_async_gen
	_write_to_iterator_queue

Static Private Attributes
	_FINISH_ITERATOR_SENTINEL = object()

Detailed Description

Definition at line 474 of file aio/_interceptor.py.

Member Function Documentation

_init_stream_request_mixin()

RequestIterableType grpc.aio._interceptor._InterceptedStreamRequestMixin._init_stream_request_mixin (   self, Optional[RequestIterableType]   request_iterator  )

private

Definition at line 482 of file aio/_interceptor.py.

_proxy_writes_as_request_iterator()

def grpc.aio._interceptor._InterceptedStreamRequestMixin._proxy_writes_as_request_iterator (   self )

private

Definition at line 499 of file aio/_interceptor.py.

_write_to_iterator_queue_interruptible()

def grpc.aio._interceptor._InterceptedStreamRequestMixin._write_to_iterator_queue_interruptible (   self, RequestType  request, InterceptedCall  call  )

private

Definition at line 508 of file aio/_interceptor.py.

done_writing()

None grpc.aio._interceptor._InterceptedStreamRequestMixin.done_writing

(

self

)

Signal peer that client is done writing.

This method is idempotent.

Definition at line 543 of file aio/_interceptor.py.

write()

None grpc.aio._interceptor._InterceptedStreamRequestMixin.write	(		self,
		RequestType	request
	)

Definition at line 521 of file aio/_interceptor.py.

Member Data Documentation

_FINISH_ITERATOR_SENTINEL

grpc.aio._interceptor._InterceptedStreamRequestMixin._FINISH_ITERATOR_SENTINEL = object()

staticprivate

Definition at line 480 of file aio/_interceptor.py.

_status_code_task

grpc.aio._interceptor._InterceptedStreamRequestMixin._status_code_task

private

Definition at line 490 of file aio/_interceptor.py.

_write_to_iterator_async_gen

grpc.aio._interceptor._InterceptedStreamRequestMixin._write_to_iterator_async_gen

private

Definition at line 488 of file aio/_interceptor.py.

_write_to_iterator_queue

grpc.aio._interceptor._InterceptedStreamRequestMixin._write_to_iterator_queue

private

Definition at line 487 of file aio/_interceptor.py.

---

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

• aio/_interceptor.py