anchor.diff:              end, Docs);
           (_Any) -> ok
       end,
  +    BorderSeqNum = rpc:call(Worker, couchbase_changes_stream, get_seq_safe, [?SCOPE, #{bucket => ?BUCKET}]),
       {ok, Pid} = ?assertMatch({ok, _}, rpc:call(Worker, couchbase_changes,
           stream, [?BUCKET, ?SCOPE, Callback]
       )),
  
positive.code:     ok;
  assert_all(Fun, List) ->
      List1 = Fun(List),
      assert_all(Fun, List1).
negative.code:             Doc2#document{value = ?VALUE(M + 1)}
          end, ?DOC(N, ?VALUE(1)), lists:seq(1, ChangesNum))
      end, lists:seq(1, DocNum))),
      check_changes_from_stream(DocNum, [?KEY(N) || N <- lists:seq(1, DocNum)], BorderSeqNum),
      ?assertEqual(ok, rpc:call(Worker, couchbase_changes, cancel_stream, [Pid])).
  
  stream_should_return_all_changes_except_mutator(Config) ->
  