Module swim.concurrent
Package swim.concurrent

Interface PullRequest<T>

All Known Implementing Classes:
PushRequest
public interface PullRequest<T>

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    drop(Throwable reason)
     
    float
    prio()
     
    void
    pull(PullContext<? super T> context)
     
    boolean
    stay(StayContext context, int backlog)
     

  • Method Details