'Get a L{Deferred} which will fire with the next event on this channel.
@rtype: L{Deferred}'

def subscribe(self):

    d = defer.Deferred(canceller=self._subscriptions.remove)
    self._subscriptions.append(d)
    return d
