From a22cc0d592ae7c2a6d36678d854fd18b7686d38c Mon Sep 17 00:00:00 2001 From: asahi Date: Sat, 3 May 2025 21:47:55 +0800 Subject: [PATCH] =?UTF-8?q?doc:=20=E9=98=85=E8=AF=BBFlux.zip=E6=96=87?= =?UTF-8?q?=E6=A1=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- spring/webflux/Reactor.md | 8 ++++++++ 1 file changed, 8 insertions(+) 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`操作。