如何將List <Single <String>>轉換爲列表<String>？

Question

我有一個列表List<Single<String>>，我想變成List<String>。

訂單應該被保留，並且所有Single應該被並行處理。

List<Single<String>> list = new ArrayList<>(); 
for (int i = 0; i < 10; i++) { 
    list.add(createSingle(i)); 
} 

// Dummy method which creates a single instance 
private Single<String> createSingle(int i) { 
    return Single.create(sub -> { 
    new Thread(() -> { 
     try { 
     Thread.sleep(800); 
     } catch (InterruptedException e) { 
     e.printStackTrace(); 
     } 
     sub.onSuccess("test_" + i); 
    }).start(); 
    }); 
} 

我最初的實現中所使用Observable.concatWith但將基本上防止並行處理，因爲每個單訂閱一個在另一個之後。

我也知道我可以將單打的列表變成一個可以發射字符串的Observable，但是我在這種情況下放棄了命令。

List<Observable<String>> obsList = list.stream().map(Single::toObservable).collect(Collectors.toList()); 
Observable.merge(obsList)..... 

Answer 1

如何

List<Single<String>> list = ... 

Observable.from(list) 
.concatMapEager(s -> s.toObservable().subscribeOn(Schedulers.computation())) 
.toList() 
.subscribe(System.out::println, Throwable::printStackTrace);