

def onConnectionMade(self, xs):
    '\n        Called when a component connection was made.\n\n        This enables traffic debugging on incoming streams.\n        '
    xs.serial = self.serial
    self.serial += 1

    def logDataIn(buf):
        log.msg(('RECV (%d): %r' % (xs.serial, buf)))

    def logDataOut(buf):
        log.msg(('SEND (%d): %r' % (xs.serial, buf)))
    if self.logTraffic:
        xs.rawDataInFn = logDataIn
        xs.rawDataOutFn = logDataOut
    xs.addObserver(xmlstream.STREAM_ERROR_EVENT, self.onError)

dataset/ETHPy150Open kuri65536/python-for-android/python-modules/twisted/twisted/words/protocols/jabber/component.py XMPPComponentServerFactory.onConnectionMade/original