如何将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);