Skip to content

Commit

Permalink
Fix javadoc
Browse files Browse the repository at this point in the history
  • Loading branch information
fredericBregier committed Jan 10, 2024
1 parent f76ab1c commit bf65e50
Showing 1 changed file with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -285,7 +285,7 @@ private boolean emitPending() {

/**
* Drain the buffer.
* <p/>
* <p>
* Calling this assumes {@code (demand > 0L && !pending.isEmpty()) == true}
*/
private void drain() {
Expand Down Expand Up @@ -336,9 +336,9 @@ private void handleException(Throwable err) {

/**
* Request a specific {@code amount} of elements to be fetched, the amount is added to the actual demand.
* <p/>
* <p>
* Pending elements in the buffer will be delivered asynchronously on the context to the handler.
* <p/>
* <p>
* This method can be called from any thread.
*
* @return {@code true} when the buffer will be drained
Expand All @@ -360,7 +360,7 @@ public boolean fetch(long amount) {

/**
* Clear the buffer synchronously.
* <p/>
* <p>
* No handler will be called.
*
* @return a reference to this, so the API can be used fluently
Expand All @@ -382,9 +382,9 @@ public synchronized void pause() {

/**
* Resume the buffer, and sets the buffer in {@code flowing} mode.
* <p/>
* <p>
* Pending elements in the buffer will be delivered asynchronously on the context to the handler.
* <p/>
* <p>
* This method can be called from any thread.
*/
public void resume() {
Expand Down

0 comments on commit bf65e50

Please sign in to comment.