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 Detail

prio

float prio()

pull

void pull(PullContext<? super T> context)

drop

void drop(Throwable reason)

stay

boolean stay(StayContext context,
             int backlog)