X-Git-Url: https://www.chiark.greenend.org.uk/ucgi/~mdw/git/mLib-python/blobdiff_plain/5b1830f325c55c70d65fd020f08dd958493e528d..e697f90228e90f5fe5f62b05124d7d43f5fd65dc:/selbuf.pyx diff --git a/selbuf.pyx b/selbuf.pyx index 35b7cf6..53964c7 100644 --- a/selbuf.pyx +++ b/selbuf.pyx @@ -24,6 +24,11 @@ ### Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. cdef class SelLineBuffer: + """ + SelLineBuffer(FILE, [lineproc = None], [eofproc = None]) + + Split an asynchronous stream into lines. + """ cdef selbuf b cdef _line cdef _eof @@ -35,12 +40,15 @@ cdef class SelLineBuffer: def __dealloc__(me): selbuf_destroy(&me.b) property activep: + """SLB.activep -> BOOL: is the buffer still active?""" def __get__(me): return _tobool(me.b.b.f & LBUF_ENABLE) property fd: + """SLB.fd -> INT: the file descriptor""" def __get__(me): return me.b.reader.fd property delim: + """SLB.delim -> CHAR | LBUF_...: line-end delimiter""" def __get__(me): if me.b.b.delim == _LBUF_CRLF or me.b.b.delim == _LBUF_STRICTCRLF: return me.b.b.delim @@ -52,6 +60,7 @@ cdef class SelLineBuffer: else: me.b.b.delim = ord(d) property size: + """SLB.size -> INT: buffer size limit""" def __get__(me): return me.b.b.sz def __set__(me, sz): @@ -59,6 +68,7 @@ cdef class SelLineBuffer: raise TypeError, 'size must be positive' selbuf_setsize(&me.b, sz) property lineproc: + """SLB.lineproc -> FUNC: call FUNC(LINE) on each line""" def __get__(me): return me._line def __set__(me, proc): @@ -66,6 +76,7 @@ cdef class SelLineBuffer: def __del__(me): me._line = None property eofproc: + """SLB.eofproc -> FUNC: call FUNC() at end-of-file""" def __get__(me): return me._eof def __set__(me, proc): @@ -73,24 +84,30 @@ cdef class SelLineBuffer: def __del__(me): me._eof = None def enable(me): + """SLB.enable(): enable the buffer, allowing lines to be emitted""" if me.b.b.f & LBUF_ENABLE: raise ValueError, 'already enabled' selbuf_enable(&me.b) me.enabled() return me def disable(me): + """SLB.disable(): disable the buffer, suspending line emission""" if not (me.b.b.f & LBUF_ENABLE): raise ValueError, 'already disabled' selbuf_disable(&me.b) me.disabled() return me def enabled(me): + """SLB.enabled(): called when buffer is enabled""" pass def disabled(me): + """SLB.disabled(): called when buffer is disabled""" pass def line(me, line): + """SLB.line(LINE): called for each completed line""" return _maybecall(me._line, (line,)) def eof(me): + """SLB.eof(): called at end-of-file""" return _maybecall(me._eof, ()) cdef void _selbfunc(char *s, size_t n, void *arg):