Class t.i.i.a.ConnectedSocket(log.Logger, styles.Ephemeral, object):

Part of twisted.internet.iocpreactor.abstract View Source View In Hierarchy

Known subclasses: twisted.internet.iocpreactor.client.ClientSocket, twisted.internet.iocpreactor.server.ServerSocket

Implements interfaces: twisted.internet.interfaces.IConsumer, twisted.internet.interfaces.IProducer, twisted.internet.interfaces.ITransport
No class docstring
Method __init__ Undocumented
Method addBufferCallback Undocumented
Method removeBufferCallback Undocumented
Method callBufferHandlers Undocumented
Method handle_connected_write Undocumented
Method handle_disconnected_write Undocumented
Method writeSequence Write a list of strings to the physical connection.
Method _cbDisconnecting Undocumented
Method handle_connected_loseConnection Undocumented
Method handle_disconnecting_loseConnection Undocumented
Method _cbWriteShutdown Undocumented
Method handle_connected_shutdown Undocumented
Method connectionLost Undocumented
Method startReading Undocumented
Method stopReading Undocumented
Method handle_connected_readDone Undocumented
Method handle_disconnecting_readDone Undocumented
Method handle_connected_readErr Undocumented
Method handle_disconnected_readErr Undocumented
Method handle_disconnected_readDone Undocumented
Method startWriting Undocumented
Method stopWriting Undocumented
Method handle_connected_writeDone Undocumented
Method handle_connected_writeErr Undocumented
Method handle_disconnected_writeErr Undocumented
Method handle_disconnected_writeDone Undocumented
Method registerProducer Register to receive data from a producer.
Method milkProducer Undocumented
Method stfuProducer Undocumented
Method unregisterProducer Stop consuming data from a producer, without disconnecting.
Method stopConsuming Undocumented
Method resumeProducing Undocumented
Method pauseProducing Undocumented
Method stopProducing Stop producing data.
Method __repr__ Undocumented
Method logPrefix Override this method to insert custom logging behavior. Its

Inherited from Ephemeral:

Method __getstate__ Undocumented
Method __setstate__ Undocumented
def __init__(self, socket, protocol, sockfactory): (source)
Undocumented
def addBufferCallback(self, handler, event): (source)
Undocumented
def removeBufferCallback(self, handler, event): (source)
Undocumented
def callBufferHandlers(self, event, *a, **kw): (source)
Undocumented
def handle_connected_write(self, data): (source)
Undocumented
def handle_disconnected_write(self, data): (source)
Undocumented
def writeSequence(self, iovec): (source)

Write a list of strings to the physical connection.

If possible, make sure that all of the data is written to the socket at once, without first copying it all into a single string.
def _cbDisconnecting(self): (source)
Undocumented
def handle_connected_loseConnection(self): (source)
Undocumented
def handle_disconnecting_loseConnection(self): (source)
Undocumented
def _cbWriteShutdown(self): (source)
Undocumented
def handle_connected_shutdown(self, write=False, read=False): (source)
Undocumented
def connectionLost(self, reason): (source)
Undocumented
def startReading(self): (source)
Undocumented
def stopReading(self): (source)
Undocumented
def handle_connected_readDone(self, bytes): (source)
Undocumented
def handle_disconnecting_readDone(self, bytes): (source)
Undocumented
def handle_connected_readErr(self, ret, bytes): (source)
Undocumented
def handle_disconnected_readErr(self, ret, bytes): (source)
Undocumented
def handle_disconnected_readDone(self, bytes): (source)
Undocumented
def startWriting(self): (source)
Undocumented
def stopWriting(self): (source)
Undocumented
def handle_connected_writeDone(self, bytes): (source)
Undocumented
def handle_connected_writeErr(self, ret, bytes): (source)
Undocumented
def handle_disconnected_writeErr(self, ret, bytes): (source)
Undocumented
def handle_disconnected_writeDone(self, bytes): (source)
Undocumented
def registerProducer(self, producer, streaming): (source)

Register to receive data from a producer.

This sets self to be a consumer for a producer. When this object runs out of data (as when a send(2) call on a socket succeeds in moving the last data from a userspace buffer into a kernelspace buffer), it will ask the producer to resumeProducing().

For IPullProducer providers, resumeProducing will be called once each time data is required.

For IPushProducer providers, pauseProducing will be called whenever the write buffer fills up and resumeProducing will only be called when it empties.
Parametersproducer(type: IProducer provider )
streamingTrue if producer provides IPushProducer, False if producer provides IPullProducer. (type: bool )
ReturnsNone
def milkProducer(self): (source)
Undocumented
def stfuProducer(self): (source)
Undocumented
def unregisterProducer(self): (source)
Stop consuming data from a producer, without disconnecting.
def stopConsuming(self): (source)
Undocumented
def resumeProducing(self): (source)
Undocumented
def pauseProducing(self): (source)
Undocumented
def stopProducing(self): (source)

Stop producing data.

This tells a producer that its consumer has died, so it must stop producing data for good.
def __repr__(self): (source)
Undocumented
def logPrefix(self): (source)
Override this method to insert custom logging behavior. Its return value will be inserted in front of every line. It may be called more times than the number of output lines.
API Documentation for twisted, generated by pydoctor.