Skip to content
This repository has been archived by the owner on Jan 19, 2022. It is now read-only.

Commit

Permalink
Add error handling mention to reactive pubsub docs (#2232)
Browse files Browse the repository at this point in the history
  • Loading branch information
elefeint committed Mar 3, 2020
1 parent c5deb6d commit 730b8b4
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions docs/src/main/asciidoc/pubsub.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -176,6 +176,9 @@ For unlimited demand, the Pub/Sub subscription will be polled regularly, at inte
For bounded demand, the `pollingPeriodMs` parameter is unused.
Instead, as many messages as possible (up to the requested number) are delivered immediately, with the remaining messages delivered as they become available.

Any exceptions thrown by the underlying message retrieval logic will be passed as an error to the stream.
The error handling operators (`Flux#retry()`, `Flux#onErrorResume()` etc.) can be used to recover.

The full range of Project Reactor operations can be applied to the stream.
For example, if you only want to fetch 5 messages, you can use `limitRequest` operation to turn the infinite stream into a finite one:

Expand Down

0 comments on commit 730b8b4

Please sign in to comment.