def pipe(self, other_task):
        other_task._source = self
        self._listeners.append(PipeListener(other_task))
        return other_task
Record a connection made event.
dataset/ETHPy150Open pudo/scrapekit/scrapekit/tasks.py/Task.pipe--crossover with--dataset/ETHPy150Open twisted/nevow/nevow/test/test_athena.py/ConnectionTestElement.connectionMade