'Called when a new update is available to stream to clients.
We need to check if the client is interested in the stream or not'

def stream_update(self, stream_name, token, data):

    if (stream_name in self.replication_streams):
        self.send_command(RdataCommand(stream_name, token, data))
    elif (stream_name in self.connecting_streams):
        logger.debug('[%s]    Queuing    RDATA    %r    %r', self.id(), stream_name, token)
        self.pending_rdata.setdefault(stream_name, []).append((token, data))
    else:
        logger.debug('[%s]    Dropping    RDATA    %r    %r', self.id(), stream_name, token)
