diff --git a/spring/webflux/Reactor.md b/spring/webflux/Reactor.md index 0aefd05..dded082 100644 --- a/spring/webflux/Reactor.md +++ b/spring/webflux/Reactor.md @@ -92,6 +92,8 @@ - [Pipeline Operations](#pipeline-operations) - [concurrency](#concurrency) - [prefetch](#prefetch-1) + - [zip](#zip) + - [zipWith](#zipwith) # Reactor ## Reactive Programming @@ -1353,5 +1355,11 @@ concurrency用于控制在途的inner sequences上限。 #### prefetch prefetch用于控制每个inner publisher在途的元素上限 +### zip +`zip`操作会将多个resource合并为一个,即`等待所有sources都发送一个元素,并且将所有发送的元素整合到一个output value中(output value通过提供的combinator进行构造)`。 +`zip` operator会持续执行上述操作,直到任一source完成(complete)。 + +#### zipWith +`zipWith`可以将当前flux和另一个publisher一起执行`zip`操作。