无法使用分组依据进行订阅

Question

我已经尝试了很多示例，但对我来说都行不通，我只是想使用以下代码接收分组结果作为列表：

  private final PublishSubject<MyObject> s;

  public RabbitMQConsumer() {
    s = PublishSubject.create();
    s.groupBy(x -> x.getName())
    .flatMapSingle(x -> x.toList())
    .subscribe(x -> System.out.println(x));
  }

这应该像示例中所说的那样工作，但是它永远不会打印出任何东西。如果我删除 groupby 它开始打印出传入的值。

知道我做错了什么吗？

Answer 1

我为你的代码做了一个示例代码并且工作正常

List<String> list = Arrays.asList("AN", "BL", "CL", "DO", "AK", "LL", "BO", "DL");
Observable.fromIterable(list).groupBy(x -> x.charAt(0))
        .flatMapSingle(x -> x.toList())
        .subscribe(x -> System.out.println(x));

输出如下：

[AN, AK]
[BL, BO]
[CL]
[DO, DL]
[LL]

为什么不重写 onError() 看看是否有错误发生

无法使用分组依据进行订阅

Unable to subscribe using group by

java

rx-java2