Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -191,15 +191,6 @@ public void setInitialDelay(Duration initialDelay) {
this.initialDelay = initialDelay;
}

/**
* Switches to long polling (RFC 8936, section 2.5): the first request of a poll asks
* the transmitter to hold it until SETs are available
* ({@code returnImmediately: false}), and a running poller sends the next request as
* soon as a response was handled.
* @param hold how long the transmitter holds a request, part of the agreement with it
* (section 2.2); the request waits that long plus a margin for the response.
* {@code null} returns to short polling.
*/
/**
* How soon the poller looks again while the poll endpoint of the stream is not known
* yet, one second by default; never longer than the interval.
Expand All @@ -209,6 +200,15 @@ public void setEndpointRetry(Duration endpointRetry) {
this.endpointRetry = endpointRetry;
}

/**
* Switches to long polling (RFC 8936, section 2.5): the first request of a poll asks
* the transmitter to hold it until SETs are available
* ({@code returnImmediately: false}), and a running poller sends the next request as
* soon as a response was handled.
* @param hold how long the transmitter holds a request, part of the agreement with it
* (section 2.2); the request waits that long plus a margin for the response.
* {@code null} returns to short polling.
*/
public void setLongPolling(Duration hold) {
SsfAssert.isTrue(hold == null || hold.isPositive(), "hold must be positive");
this.longPollingHold = hold;
Expand Down
Loading