Comms

• Comms
  • CommsManager
    • CommsManager.address
    • CommsManager.beat()
    • CommsManager.call()
    • CommsManager.call_safe()
    • CommsManager.cmd()
    • CommsManager.cmd_async()
    • CommsManager.cmd_pubsub()
    • CommsManager.cmd_pubsub_async()
    • CommsManager.cmd_recv()
    • CommsManager.cmd_recv_async()
    • CommsManager.connect()
    • CommsManager.connect_pubsub()
    • CommsManager.connect_recv()
    • CommsManager.connect_send()
    • CommsManager.connected()
    • CommsManager.disconnect()
    • CommsManager.disconnect_recv()
    • CommsManager.disconnect_send()
    • CommsManager.hand()
    • CommsManager.handshake()
    • CommsManager.heart()
    • CommsManager.listen()
    • CommsManager.listen_async()
    • CommsManager.logger
    • CommsManager.port
    • CommsManager.process_msg()
    • CommsManager.pubsub_port
    • CommsManager.recv()
    • CommsManager.recv_async()
    • CommsManager.recv_pubsub()
    • CommsManager.recv_pubsub_async()
    • CommsManager.register_reply_future()
    • CommsManager.reply()
    • CommsManager.send()
    • CommsManager.send_async()
    • CommsManager.send_exception()
    • CommsManager.send_pubsub()
    • CommsManager.send_pubsub_async()
    • CommsManager.send_recv()
    • CommsManager.send_recv_async()
    • CommsManager.shake()
    • CommsManager.shaken()
    • CommsManager.start_heartbeat()
    • CommsManager.stop()
    • CommsManager.uid_address()
    • CommsManager.uid_port()
    • CommsManager.wait()
    • CommsManager.wait_for()
• Serialisation
  • serialise()
  • deserialise()
• Compression
  • maybe_compress()
  • decompress()