class documentation

class TestConsumer: (source)

View In Hierarchy

A very basic test consumer for use with the NonStreamingProducerTests.

Method __init__ Undocumented
Method registerProducer Registers a single producer with this consumer. Just keeps track of it.
Method unregisterProducer Forget the producer we had previously registered.
Method write Some data was written to the consumer: stores it for later use.
Instance Variable producer Undocumented
Instance Variable producerStreaming Undocumented
Instance Variable writes Undocumented
def __init__(self): (source)

Undocumented

def registerProducer(self, producer, streaming): (source)

Registers a single producer with this consumer. Just keeps track of it.

Parameters
producerThe producer to register.
streamingWhether the producer is a streaming one or not.
def unregisterProducer(self): (source)

Forget the producer we had previously registered.

def write(self, data): (source)

Some data was written to the consumer: stores it for later use.

Parameters
dataThe data to write.
producer = (source)

Undocumented

producerStreaming = (source)

Undocumented

Undocumented