Module swim.concurrent
Package swim.concurrent

Interface Stay<T>

All Superinterfaces:
Cont<T>
public interface Stay<T> extends Cont<T>
Backpressure aware continuation.
See Also:

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    stay(StayContext context, int backlog)
    Invoked when the asynchronous operation needs to wait before proceeding.

    Methods inherited from interface swim.concurrent.Cont

    bind, trap

  • Method Details

    • stay

      boolean stay(StayContext context, int backlog)
      Invoked when the asynchronous operation needs to wait before proceeding. Returns true if the operation should continue; returns false if the operation should preemptively terminate and Cont.trap(Throwable) the continuation.