java - react 器 Spring WebFlux : Explain please difference between last() and takeLast() methods

Question

有人可以解释一下last()和takeLast()方法之间的区别吗？正如文档所述:

last() - 将完成信号之前观察到的最后一个元素作为 Mono 发出，或者如果源为空，则发出 NoSuchElementException 错误。对于被动版本，请使用 takeLast(int)

takeLast() - 发出此 Flux 在完成之前发出的最后 N 个值。

对于我来说也是一样的。我无法理解其中的差异。有人可以用一个简单的例子来解释我吗？提前致谢

Answer 1

基里尔

takeLast(int n) 接受指示流中应保留多少元素的整数示例:

Flux.just(1, 2, 3, 4)
        .takeLast(3)
        .subscribe(System.out::println);

结果为

234

同时，last() 方法仅涉及最后发出的元素。

Flux.just(1, 2, 3, 4)
        .last()
        .subscribe(System.out::print);

输出为

4

<小时/>

结论:takeLast(1)等于last()