com.spotify.protocol.client

Class PendingResultBase<T>

java.lang.Object

com.spotify.protocol.client.PendingResultBase<T>

Type Parameters:

T - data type of the result

All Implemented Interfaces:

PendingResult<T>

Direct Known Subclasses:

CallResult, Subscription

public abstract class PendingResultBase<T>
extends java.lang.Object
implements PendingResult<T>

Constructor Summary

Constructors

Constructor and Description
PendingResultBase()

Method Summary

Modifier and Type	Method and Description
Result<T>	await() Block until a Result is available.
Result<T>	await(long timeout, java.util.concurrent.TimeUnit timeUnit) Block until a Result is received or in has expired.
void	cancel() Cancel this PendingResultBase to stop receiving callbacks.
void	deliverError(java.lang.Throwable t)
void	deliverResult(Result<T> result)
boolean	isCanceled()
PendingResult<T>	setErrorCallback(ErrorCallback errorCallback) Set callback notified if this PendingResult fails

Methods inherited from class java.lang.Object

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

Constructor Detail

PendingResultBase

public PendingResultBase()

Method Detail

cancel

public void cancel()

Cancel this PendingResultBase to stop receiving callbacks.

Specified by:

cancel in interface PendingResult<T>

isCanceled

public boolean isCanceled()

Specified by:

isCanceled in interface PendingResult<T>

Returns:

true if cancel has been called on this PendingResultBase

await

public Result<T> await()

Block until a Result is available. Warning, this call will block forever if no result is received. Consider using PendingResult.await(long, TimeUnit)

Specified by:

await in interface PendingResult<T>

Returns:

the Result

await

public Result<T> await(long timeout,
                       java.util.concurrent.TimeUnit timeUnit)

Block until a Result is received or in has expired.

Specified by:

await in interface PendingResult<T>

Parameters:

timeout - the timeout

timeUnit - the TimeUnit in which timeout is interpreted.

Returns:

the Result

setErrorCallback

public PendingResult<T> setErrorCallback(ErrorCallback errorCallback)

Set callback notified if this PendingResult fails

Specified by:

setErrorCallback in interface PendingResult<T>

Parameters:

errorCallback - the callback

Returns:

itself to enable chainging of operations

deliverResult

public void deliverResult(Result<T> result)

deliverError

public void deliverError(java.lang.Throwable t)