Module swim.concurrent

Package swim.concurrent

Class PushRequest<T>

java.lang.Object

swim.concurrent.PushRequest<T>

All Implemented Interfaces:

PullRequest<T>

public class PushRequest<T>
extends Object
implements PullRequest<T>

Constructor Summary

Constructors

Constructor	Description
PushRequest(T value)
PushRequest(T value, float prio)

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PushRequest

public PushRequest(T value,
 float prio)

PushRequest

public PushRequest(T value)

Method Details

get

public final T get()

prio

public final float prio()

Specified by:

prio in interface PullRequest<T>

pull

public void pull(PullContext<? super T> context)

Specified by:

pull in interface PullRequest<T>

drop

public void drop(Throwable reason)

Specified by:

drop in interface PullRequest<T>

stay

public boolean stay(StayContext context,
 int backlog)

Specified by:

stay in interface PullRequest<T>