Implements interfaces: twisted.internet.interfaces.IConsumer

I consume single-item query results, doing the specified f-args-kw for each.

Instance Variable N The number of rows between calls to progressCall.
Method __init__ Undocumented
Method registerProducer Undocumented
Method unregisterProducer Undocumented
Method write All I care about is having rows written. If you specified a progressCall to my constructor, I will call it with no argument every N rows.
N =
The number of rows between calls to progressCall.
def __init__(self, f, **kw):
Undocumented
def registerProducer(self, producer, streaming):
Undocumented
def unregisterProducer(self):
Undocumented
def write(self, rows):

All I care about is having rows written. If you specified a progressCall to my constructor, I will call it with no argument every N rows.

API Documentation for logalyzer, generated by pydoctor at 2021-09-18 08:41:09.