

def registerProducer(self, producer, streaming):
    if (self._writer is None):
        producer.stopProducing()
    else:
        self._writer.registerProducer(producer, streaming)

dataset/ETHPy150Open nlloyd/SubliminalCollaborator/libs/twisted/internet/_posixstdio.py StandardIO.registerProducer/original