Skip to content

Commit

Permalink
Add comments about don't cache the EmitFailureHandle#busyLooping retu…
Browse files Browse the repository at this point in the history
…rning value.
  • Loading branch information
He-Pin committed Oct 10, 2022
1 parent 6fc9496 commit 1b4f812
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion reactor-core/src/main/java/reactor/core/publisher/Sinks.java
Original file line number Diff line number Diff line change
Expand Up @@ -269,7 +269,8 @@ public interface EmitFailureHandler {
* <p>
* As a result there will always be some delay between this computation and the actual first
* use of the handler (at a minimum, the time it takes for the first sink emission attempt).
* Consider this when choosing the {@link Duration}, and probably prefer something above 100ms.
* Consider this when choosing the {@link Duration}, and probably prefer something above 100ms,
* and don't cache the returning handler for later usage.
*
* @param duration {@link Duration} for the deadline
* @return an optimistic and bounded busy-looping {@link EmitFailureHandler}
Expand Down

0 comments on commit 1b4f812

Please sign in to comment.