'receiving clear-text data from local rpyc Stream and writing obfuscated data to upstream'

def upstream_recv(self, data):

    if hasattr(self, 'receivedUpstream'):
        return self.receivedUpstream(data)
        '    obfsproxy    style    alias    '
    raise NotImplementedError()
