'For a given stream get all updates since token. This is called when
a client first subscribes to a stream.'

@measure_func('repl.get_stream_updates')
def get_stream_updates(self, stream_name, token):

    stream = self.streams_by_name.get(stream_name, None)
    if (not stream):
        raise Exception('unknown    stream    %s', stream_name)
    return stream.get_updates_since(token)
