def subscribe(self):
        d = defer.Deferred(canceller=self._subscriptions.remove)
        self._subscriptions.append(d)
        return d
Get a L{Deferred} which will fire with the next event on this channel.
dataset/ETHPy150Open ClusterHQ/flocker/flocker/restapi/testtools.py/EventChannel.subscribe