def pipe(self, data):
    if self.piping_processor.is_listening():
        return self.piping_processor.pipe(data)
    else:
        return data
def pipe(self, data):
    if self.piping_processor.is_listening():
        return self.piping_processor.pipe(data)
    else:
        return data