Index

_

__getitem__() (aiozmq.rpc.AbstractHandler method)

A

abort() (aiozmq.ZmqTransport method) AbstractHandler (class in aiozmq.rpc) aiozmq (module) aiozmq.rpc (module)

annotaion arguments (aiozmq.rpc.GenericError attribute) asyncio at_closing() (aiozmq.ZmqStream method) AttrHandler (class in aiozmq.rpc)

B

bind() (aiozmq.ZmqTransport method)

bindings() (aiozmq.ZmqTransport method)

C

call (aiozmq.rpc.RPCClient attribute) callable close() (aiozmq.rpc.Service method) (aiozmq.ZmqStream method) (aiozmq.ZmqTransport method) connect() (aiozmq.ZmqTransport method) connect_pipeline() (in module aiozmq.rpc)

connect_pubsub() (in module aiozmq.rpc) connect_rpc() (in module aiozmq.rpc) connection_lost() (aiozmq.ZmqProtocol method) connection_made() (aiozmq.ZmqProtocol method) connections() (aiozmq.ZmqTransport method) create_zmq_connection() (aiozmq.ZmqEventLoop method) (in module aiozmq) create_zmq_stream() (in module aiozmq)

D

disable_monitor() (aiozmq.ZmqTransport method)

disconnect() (aiozmq.ZmqTransport method) drain() (aiozmq.ZmqStream method)

E

enable_monitor() (aiozmq.ZmqTransport method) endpoint enduser

Error event_received() (aiozmq.ZmqProtocol method) exc_type (aiozmq.rpc.GenericError attribute) exception() (aiozmq.ZmqStream method)

F

feed_closing() (aiozmq.ZmqStream method)

feed_event() (aiozmq.ZmqStream method) feed_msg() (aiozmq.ZmqStream method)

G

GenericError get_child_watcher() (aiozmq.ZmqEventLoopPolicy method) get_event_loop() (aiozmq.ZmqEventLoopPolicy method) get_extra_info() (aiozmq.ZmqStream method) (aiozmq.ZmqTransport method)

get_write_buffer_limits() (aiozmq.ZmqTransport method) get_write_buffer_size() (aiozmq.ZmqTransport method) getsockopt() (aiozmq.ZmqTransport method)

L

logger (in module aiozmq.rpc)

M

method() (in module aiozmq.rpc)

msg_received() (aiozmq.ZmqProtocol method) msgpack

N

new_event_loop() (aiozmq.ZmqEventLoopPolicy method)

NotFoundError notify (aiozmq.rpc.PipelineClient attribute)

P

ParameterError pause_reading() (aiozmq.ZmqTransport method) pause_writing() (aiozmq.ZmqProtocol method) PipelineClient (class in aiozmq.rpc) publish() (aiozmq.rpc.PubSubClient method)

PubSubClient (class in aiozmq.rpc) Python Enhancement Proposals PEP 3107 PEP 3151 PEP 3156, [1] pyzmq

R

read() (aiozmq.ZmqStream method) read_event() (aiozmq.ZmqStream method)

resume_reading() (aiozmq.ZmqTransport method) resume_writing() (aiozmq.ZmqProtocol method) RPCClient (class in aiozmq.rpc)

S

serve_pipeline() (in module aiozmq.rpc) serve_pubsub() (in module aiozmq.rpc) serve_rpc() (in module aiozmq.rpc) Service (class in aiozmq.rpc) ServiceClosedError set_child_watcher() (aiozmq.ZmqEventLoopPolicy method) set_event_loop() (aiozmq.ZmqEventLoopPolicy method)

set_exception() (aiozmq.ZmqStream method) set_read_buffer_limits() (aiozmq.ZmqStream method) set_transport() (aiozmq.ZmqStream method) set_write_buffer_limits() (aiozmq.ZmqTransport method) setsockopt() (aiozmq.ZmqTransport method) subscribe() (aiozmq.ZmqTransport method) subscriptions() (aiozmq.ZmqTransport method)

T

trafaret

transport (aiozmq.rpc.Service attribute) (aiozmq.ZmqStream attribute)

U

unbind() (aiozmq.ZmqTransport method)

unsubscribe() (aiozmq.ZmqTransport method)

V

version (in module aiozmq)

version_info (in module aiozmq)

W

wait_closed() (aiozmq.rpc.Service method) with_timeout() (aiozmq.rpc.RPCClient method)

write() (aiozmq.ZmqStream method) (aiozmq.ZmqTransport method)

Z

ZeroMQ ZmqEventLoop (class in aiozmq) ZmqEventLoopPolicy (class in aiozmq)

ZmqProtocol (class in aiozmq) ZmqStream (class in aiozmq) ZmqStreamClosed ZmqTransport (class in aiozmq)