Как создать наблюдаемую разницу между двумя отсортированными наблюдаемыми?

Вот как я бы сделал это в rxjava, подразумевая, что две наблюдаемые имеют одинаковую длину.

    Observable<Integer> obs1 = Observable.just(1, 2, 4, 6);
    Observable<Integer> obs2 = Observable.just(1, 3, 4, 5);

    obs1.zipWith(obs2, (integer, integer2) -> {
        if (!Objects.equals(integer, integer2)) {
            return Observable.just(integer).concatWith(Observable.just(integer2));
        } else {
            return Observable.empty();
        }
    })
      .flatMap(observable -> observable)
      .sorted()
      .forEach(System.out::println);

ИЗМЕНИТЬ

Другим подходом было бы использование коллекции

    Observable<Integer> obs1 = Observable.just(1, 2, 4);
    Observable<Integer> obs2 = Observable.just(1, 3, 4, 5);


    obs1.mergeWith(obs2)
            .sorted()
            .reduce(new ArrayList<Integer>(), (integers, integer) -> {
                if (integers.contains(integer)) {
                    integers.remove(integer);
                } else {
                    integers.add(integer);
                }
                return integers;
            })
            .flatMapIterable(integers -> integers)
            .forEach(System.out::println);

Я не думаю, что в RxJava есть много способов сделать эту симметричную разницу «в реальном времени» ... Главным образом потому, что ваше исходное предположение (наблюдаемые сортируются) не может быть сделано с помощью общих операторов, поэтому немногие помогут вам с этим.

Однако вы можете попытаться написать для этой цели собственный оператор, вдохновленный sequenceEqual: он внутренне продвигается шаг за шагом между двумя издателями для выполнения сравнения на равенство, так что это близко к тому, что вы хотите сделать.