0

我有一个来自 N 个可观察值的合并 EventStream。从这个值我想要最小的一个。例如：

    Var<Integer> a = Var.newSimpleVar(2);
    Var<Integer> b = Var.newSimpleVar(3);
    Var<Integer> c = Var.newSimpleVar(4);
    ...

    EventStream<Integer> m = EventStreams.merge(a.values(), b.values(), c.values(), ...);

    m = m.filter(integer -> integer > 1).accumulate((i1, i2) -> Math.min(i1, i2));
    m.subscribe(integer -> System.out.println(integer));


    a.setValue(0); // At this point the Input is filtered and not emitted also I dont want the last value "2" in the accumulation. 
    b.setValue(5);
    c.setValue(3);
    //Output is always "2".

我的问题是我希望在第一个过滤值之后还有一个新的初始值用于累积。在这种情况下，例如“Integer.MAX_VALUE”之类的东西。

因此，累积中的下一个比较不是：
"Math.min(2,5)" -> "Math.min(2,3)"
而是
"Math.min(MAX_VALUE,5)" -> "Math.min (5,3)"。

所以输出不应该是：
2, 2, 2, 2, 2
但是

a -> 2：输出最小值 2
b -> 3：输出最小值 2
c -> 4：输出最小值 2

a -> 0：OK 条件（值 < 1）为真。现在重置或更好地重复流（不保留累积的最后一个值 2）

b -> 5：最小输出 5
c -> 3：最小输出 3
a -> 4：最小输出 3
...

4

2 回答 2

1

我会用

EventStreams.combine(a.values(), b.values(), c.values())
            .map(t3 -> t3.map((a, b, c) -> min3(a, b, c)));

您定义min3取 3 个值中的最小值，但忽略零。

于 2017-08-18T21:53:22.513 回答
0

好的，我找到了解决方案。忽略零是一个非常好的提示。谢谢托马斯：）

    Var<Integer> a = Var.newSimpleVar(2);
    Var<Integer> b = Var.newSimpleVar(3);
    Var<Integer> c = Var.newSimpleVar(4);
    ...

    EventStream<Integer> m = EventStreams.merge(a.values(), b.values(), c.values(), ...);
    m = m.accumulate((i1, i2) -> i2 < 1 ? Integer.MAX_VALUE : Math.min(i1, i2)).filter(integer -> integer != Integer.MAX_VALUE);
    m.subscribe(integer -> System.out.println(integer));

    a.setValue(0);
    b.setValue(5);
    c.setValue(3);
    a.setValue(4);

输出为：
a -> 2 ：输出最小值 2
b -> 3 ：输出最小值 2
c -> 4 ：输出最小值 2

a -> 0 : 无输出

b -> 5：最小输出 5
c -> 3：最小输出 3
a -> 4：最小输出 3

所以问题是我不能在累积执行之前过滤（在这种情况下）。还有一些问题，例如，如果此流中的第一个值为零（修复看起来像... (i1, i2) -> i1 < 1 ? i2 : i2 < 1 ? Integer.MAX_VALUE ...）。但无论如何，在我的情况下或类似的情况下，这种解决方案有效或应该有效；）

于 2017-08-20T04:32:48.427 回答