Index
_
|
A
|
B
|
C
|
D
|
E
|
F
|
H
|
I
|
K
|
L
|
M
|
N
|
O
|
P
|
R
|
S
|
T
|
U
|
W
_
_decorate_method() (prpc.method_locator.TreeMethodLocator method)
A
AbstractMethodLocator (class in prpc.method_locator)
accept() (in module prpc.platform.ws_aiohttp)
(prpc.connection.Connection method)
ACCEPTED (prpc.protocol.constants.CallState attribute)
ACCEPTING (prpc.protocol.constants.CallState attribute)
active (prpc.connection.Connection attribute)
add_iterable() (prpc.utils.repr_builder.ReprBuilder method)
add_mapping() (prpc.utils.repr_builder.ReprBuilder method)
add_value() (prpc.utils.repr_builder.ReprBuilder method)
args (prpc.call_context.CallContext attribute)
AsyncServer (class in prpc.platform.ws_aiohttp)
B
BINARY (prpc.platform.generic.MessageType attribute)
BISTREAM (prpc.protocol.constants.CallType attribute)
C
call_bistream() (prpc.connection.Connection method)
call_istream() (prpc.connection.Connection method)
call_ostream() (prpc.connection.Connection method)
call_simple() (prpc.connection.Connection method)
call_type (prpc.call_context.CallContext attribute)
call_unary() (prpc.connection.Connection method)
CallContext (class in prpc.call_context)
CallState (class in prpc.protocol.constants)
CallType (class in prpc.protocol.constants)
cancel() (prpc.rpc_response.RpcResponse method)
CANCELLED (prpc.protocol.constants.CallState attribute)
cause_message (prpc.exceptions.RpcError attribute)
(prpc.exceptions.RpcRemoteError attribute)
(prpc.protocol.messages.ErrorDescription attribute)
cause_type (prpc.exceptions.RpcError attribute)
(prpc.exceptions.RpcRemoteError attribute)
(prpc.protocol.messages.ErrorDescription attribute)
CLIENT (prpc.protocol.constants.ConnectionMode attribute)
CLOSE (prpc.platform.generic.MessageType attribute)
close() (prpc.connection.Connection method)
(prpc.platform.generic.MessageSocket method)
(prpc.stream.Stream method)
close_code (prpc.platform.generic.MessageSocket attribute)
close_sync() (prpc.stream.Stream method)
closed (prpc.platform.generic.MessageSocket attribute)
CLOSED (prpc.protocol.constants.ConnectionState attribute)
(prpc.protocol.constants.StreamState attribute)
CLOSING (prpc.protocol.constants.ConnectionState attribute)
(prpc.protocol.constants.StreamState attribute)
connect() (in module prpc.platform.ws_aiohttp)
(prpc.connection.Connection method)
connected (prpc.connection.Connection attribute)
CONNECTED (prpc.protocol.constants.ConnectionState attribute)
Connection (class in prpc.connection)
connection (prpc.call_context.CallContext attribute)
ConnectionMode (class in prpc.protocol.constants)
ConnectionState (class in prpc.protocol.constants)
D
data (prpc.connection.Connection attribute)
data_available (prpc.stream.Stream attribute)
DISCONNECTED (prpc.protocol.constants.ConnectionState attribute)
E
ERROR (prpc.platform.generic.MessageType attribute)
ErrorDescription (class in prpc.protocol.messages)
expand_args() (in module prpc.utils.decorators)
F
feed() (prpc.stream.Stream method)
finally_error() (in module prpc.exceptions)
FINISHED (prpc.protocol.constants.CallState attribute)
format() (prpc.utils.repr_builder.ReprBuilder method)
format_traceback_string() (in module prpc.exceptions)
from_bytes() (prpc.protocol.messages.ProtocolMessage class method)
H
HANDSHAKE (prpc.protocol.constants.CallType attribute)
handshake_data (prpc.connection.Connection attribute)
HandshakeData (class in prpc.protocol.messages)
I
id (prpc.connection.Connection attribute)
(prpc.protocol.messages.HandshakeData attribute)
InvalidCallState
InvalidStreamMode
InvalidStreamState
is_closed (prpc.stream.Stream attribute)
is_open (prpc.stream.Stream attribute)
is_readable (prpc.stream.Stream attribute)
is_writable (prpc.stream.Stream attribute)
ISTREAM (prpc.protocol.constants.CallType attribute)
K
kwargs (prpc.call_context.CallContext attribute)
L
locator (prpc.call_context.CallContext attribute)
(prpc.connection.Connection attribute)
loop (prpc.call_context.CallContext attribute)
(prpc.connection.Connection attribute)
M
make_websocket_factory() (in module prpc.platform.ws_aiohttp)
message (prpc.protocol.messages.ErrorDescription attribute)
message_class() (in module prpc.protocol.messages)
MessageSocket (class in prpc.platform.generic)
MessageType (class in prpc.platform.generic)
(class in prpc.protocol.constants)
method (prpc.call_context.CallContext attribute)
method() (in module prpc.method_locator)
METHOD_ERROR (prpc.protocol.constants.ResponseStatus attribute)
METHOD_NOT_FOUND (prpc.protocol.constants.ResponseStatus attribute)
mode (prpc.connection.Connection attribute)
N
NEW (prpc.protocol.constants.CallState attribute)
(prpc.protocol.constants.ConnectionMode attribute)
(prpc.protocol.constants.ConnectionState attribute)
(prpc.protocol.constants.StreamState attribute)
O
on_close (prpc.connection.Connection attribute)
(prpc.stream.Stream attribute)
on_write (prpc.stream.Stream attribute)
OPEN (prpc.protocol.constants.StreamState attribute)
open() (prpc.stream.Stream method)
OSTREAM (prpc.protocol.constants.CallType attribute)
P
pack() (in module prpc.protocol.messages)
PENDING (prpc.protocol.constants.ConnectionState attribute)
protocol_version (prpc.protocol.messages.HandshakeData attribute)
ProtocolMessage (class in prpc.protocol.messages)
prpc.call_context (module)
prpc.connection (module)
prpc.exceptions (module)
prpc.method_locator (module)
prpc.platform (module)
prpc.platform.ws_aiohttp (module)
prpc.protocol.constants (module)
prpc.protocol.messages (module)
prpc.rpc_response (module)
prpc.stream (module)
prpc.utils.decorators (module)
prpc.utils.repr_builder (module)
prpc.utils.signal (module)
R
READ (prpc.protocol.constants.StreamMode attribute)
receive() (prpc.platform.generic.MessageSocket method)
(prpc.stream.Stream method)
remote_traceback (prpc.exceptions.RpcError attribute)
(prpc.exceptions.RpcRemoteError attribute)
ReprBuilder (class in prpc.utils.repr_builder)
REQUEST_CALL_CANCEL (prpc.protocol.constants.MessageType attribute)
REQUEST_CALL_START (prpc.protocol.constants.MessageType attribute)
REQUEST_HANDSHAKE (prpc.protocol.constants.MessageType attribute)
REQUEST_STREAM_CLOSE (prpc.protocol.constants.MessageType attribute)
REQUEST_STREAM_MESSAGE (prpc.protocol.constants.MessageType attribute)
RequestCallCancel (class in prpc.protocol.messages)
RequestCallStart (class in prpc.protocol.messages)
RequestHandshake (class in prpc.protocol.messages)
RequestStreamClose (class in prpc.protocol.messages)
RequestStreamMessage (class in prpc.protocol.messages)
resolve() (prpc.method_locator.AbstractMethodLocator method)
(prpc.method_locator.TreeMethodLocator method)
RESPONSE_HANDSHAKE (prpc.protocol.constants.MessageType attribute)
RESPONSE_RESULT (prpc.protocol.constants.MessageType attribute)
RESPONSE_STREAM_CLOSE (prpc.protocol.constants.MessageType attribute)
RESPONSE_STREAM_MESSAGE (prpc.protocol.constants.MessageType attribute)
ResponseHandshake (class in prpc.protocol.messages)
ResponseResult (class in prpc.protocol.messages)
ResponseStatus (class in prpc.protocol.constants)
ResponseStreamClose (class in prpc.protocol.messages)
ResponseStreamMessage (class in prpc.protocol.messages)
result (prpc.rpc_response.RpcResponse attribute)
RpcCallTimeoutError
RpcCancelledError
RpcConnectionClosedError
RpcConnectionRejectedError
RpcConnectionTimeoutError
RpcError
RpcLocalError
RpcMethodError
RpcMethodNotFoundError
RpcRemoteError
RpcResponse (class in prpc.rpc_response)
RpcServerError
RpcStreamTimeoutError
RpcUnknownError
S
send() (prpc.platform.generic.MessageSocket method)
(prpc.stream.Stream method)
(prpc.utils.signal.Signal method)
SENDING (prpc.protocol.constants.CallState attribute)
SERVER (prpc.protocol.constants.ConnectionMode attribute)
SERVER_ERROR (prpc.protocol.constants.ResponseStatus attribute)
shutdown() (prpc.platform.ws_aiohttp.AsyncServer method)
Signal (class in prpc.utils.signal)
start() (prpc.platform.ws_aiohttp.AsyncServer method)
state (prpc.connection.Connection attribute)
Stream (class in prpc.stream)
stream (prpc.call_context.CallContext attribute)
(prpc.rpc_response.RpcResponse attribute)
StreamMode (class in prpc.protocol.constants)
StreamState (class in prpc.protocol.constants)
SUCCESS (prpc.protocol.constants.ResponseStatus attribute)
T
TEXT (prpc.platform.generic.MessageType attribute)
to_bytes() (prpc.protocol.messages.ProtocolMessage method)
to_tuple() (prpc.protocol.messages.ProtocolMessage method)
trace (prpc.protocol.messages.ErrorDescription attribute)
TreeMethodLocator (class in prpc.method_locator)
U
UNARY (prpc.protocol.constants.CallType attribute)
unpack() (in module prpc.protocol.messages)
user_data (prpc.protocol.messages.HandshakeData attribute)
W
wait() (prpc.platform.ws_aiohttp.AsyncServer method)
wrap_exception() (prpc.exceptions.RpcRemoteError class method)
WRITE (prpc.protocol.constants.StreamMode attribute)
Table Of Contents
API Reference
Quick search