com.spotify.flo.context

Class AwaitingConsumer<T>

java.lang.Object

com.spotify.flo.context.AwaitingConsumer<T>

All Implemented Interfaces:

Consumer<T>

public class AwaitingConsumer<T>
extends Object
implements Consumer<T>

A Consumer that allows for synchronously waiting for the value to arrive.

Constructor Summary

Constructors

Constructor and Description
AwaitingConsumer()

Method Summary

Modifier and Type	Method and Description
void	accept(T t)
boolean	await()
boolean	await(long time, TimeUnit unit)
T	awaitAndGet()
static <T> AwaitingConsumer<T>	create()
T	get()
boolean	isAvailable()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Consumer

andThen

Constructor Detail

AwaitingConsumer

public AwaitingConsumer()

Method Detail

create

public static <T> AwaitingConsumer<T> create()

accept

public void accept(T t)

Specified by:

accept in interface Consumer<T>

get

public T get()

isAvailable

public boolean isAvailable()

await

public boolean await()
              throws InterruptedException

Throws:

InterruptedException

await

public boolean await(long time,
                     TimeUnit unit)
              throws InterruptedException

Throws:

InterruptedException

awaitAndGet

public T awaitAndGet()
              throws InterruptedException

Throws:

InterruptedException