class documentation

class TestConsumer:

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):

Undocumented

def registerProducer(self, producer: object, streaming: bool):

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

Parameters
producer:objectThe producer to register.
streaming:boolWhether the producer is a streaming one or not.
def unregisterProducer(self):

Forget the producer we had previously registered.

def write(self, data: bytes):

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

Parameters
data:bytesThe data to write.
producer: object =

Undocumented

producerStreaming: bool | None =

Undocumented

writes: list[bytes] =

Undocumented