'Got data from upstream. We need to obfuscated and proxy them downstream.'

def receivedUpstream(self, data):

    if (not self.send_crypto):
        self.queued_data += data.read()
        return
    message = self.send_crypto.crypt(data.read())
    self.circuit.downstream.write(message)
