This is an abstract class. You must derive from this class, and add
the two methods collect_incoming_data() and found_terminator()
|
|
|
|
|
| collect_incoming_data(self,
data) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| push_with_producer(self,
producer) |
|
|
|
|
readable(self)
predicate for inclusion in the readable for select() |
|
|
|
|
writable(self)
predicate for inclusion in the writable for select() |
|
|
|
|
close_when_done(self)
automatically close this channel once the outgoing queue is empty |
|
|
|
|
|
|
|
|
|
|
|
|
Inherited from asyncore.dispatcher:
__getattr__,
__repr__,
accept,
add_channel,
bind,
close,
connect,
create_socket,
del_channel,
handle_accept,
handle_connect,
handle_error,
handle_expt,
handle_expt_event,
handle_read_event,
handle_write_event,
listen,
log,
log_info,
recv,
send,
set_reuse_addr,
set_socket
|