Reactor

class AsyncoreReactor

Bases: object

logger = <logging.Logger object>
start()
add_timer_absolute(timeout, callback)
add_timer(delay, callback)
shutdown()
new_connection(address, connect_timeout, socket_options, connection_closed_callback, message_callback)
class AsyncoreConnection(map, address, connect_timeout, socket_options, connection_closed_callback, message_callback)

Bases: hazelcast.connection.Connection, asyncore.dispatcher

sent_protocol_bytes = False
handle_connect()
handle_read()
handle_write()
handle_close()
handle_error()
readable()
write(data)

Writes data to this connection when sending messages.

Parameters:data – (Data), data to be written to connection.
writable()
close(cause)

Closes the connection.

Parameters:cause – (Exception), the cause of closing the connection.
class Timer(end, timer_ended_cb, timer_canceled_cb)

Bases: object

canceled = False
cancel()
check_timer(now)