Блог

Наличие двух потоков, подобных следующему

 Stream 1: A -- B -- C -- D
Stream 2: 3 -- 1 -- 2 -- 4
  

Я хотел бы вывести

 Output: A1 -- B2 -- C3 -- D4
  

или

 Output: 3C -- 2B -- 1A -- 4D
  

Где каждая буква сопоставляется с ее положением в алфавите.
Я пробовал использовать операторы .zip и .combineLatest , но не получил нужного результата.

На самом деле это упрощение моей проблемы, на самом деле. A, B и C — это объекты, которые имеют свойства типа 1,2 или 3. Итак, я могу сделать что-то вроде A.position() = 1

Есть ли оператор, который конкретно решает мою проблему, или мне придется использовать хэш-карту и сопоставлять эти объекты самостоятельно?

Заранее спасибо.

Используйте Observable.toSortedList , как показано ниже:

 Observable<Data> s1 = Observable.from(new Data[]{new Data(3), new Data(1), new Data(2), new Data(4)});
Observable<String> s2 = Observable.from(new String[]{"A", "B", "C", "D"});

Observable.zip(
        s1.toSortedList(this::compare).flatMap(Observable::from),
        s2,
        (d, s) -> s   d.number
).subscribe(s -> {
    //Output: A1 -- B2 -- C3 -- D4
});
  

compare способ:

 private Integer compare(Data a, Data b) {
    return a.number.equals(b.number) ? 0 : (a.number < b.number ? -1 : 1);
}
  

Data класс:

 class Data {
    private final Integer number;

    Data(Integer number) {
        this.number = number;
    }
}
  

я бы попробовал что-то вроде .flatMap() в одном потоке с .groupBy (ключ) в другом потоке, который будет выдавать Observable<GroupedObservable<YourType>>

или иным образом используйте .toMap() или .toMultimap() в другом потоке, который создаст наблюдаемые<Map<K,Collection<T>>>

не уверен, ожидаете ли вы определенного порядка

Вы можете использовать модульно протестированный оператор match из rxjava-extras 0.8.0.3 (или более поздней версии, если она доступна). Артефакт опубликован на Maven Central.

Добавьте это в свой pom.xml:

 <dependency>
  <groupId>com.github.davidmoten</groupId>
  <artifactId>rxjava-extras</artifactId>
  <version>0.8.0.3</version>
</dependency>
  

Пример:

 Observable<Integer> a = Observable.just(1, 2, 4, 3);
Observable<Integer> b = Observable.just(1, 2, 3, 5, 6, 4);
Obs.match(a, b,
     x -> x, // key to match on for a
     x -> x, // key to match on for b
     (x, y) -> x // combiner
    )
   .forEach(System.out::println);
  

Вывод:

 1
2
4
3