org.gradle.messaging.dispatch

Class DelayedReceive<T>

java.lang.Object

org.gradle.messaging.dispatch.DelayedReceive<T>

All Implemented Interfaces:

Stoppable, Receive<T>

public class DelayedReceive<T>
extends Object
implements Stoppable, Receive<T>

Constructor Summary

Constructors

Constructor and Description
DelayedReceive(TimeProvider timeProvider)

Method Summary

Methods

Modifier and Type	Method and Description
void	clear() Removes all queued messages.
void	dispatchLater(T message, int delayValue, TimeUnit delayUnits) Dispatches the given message after the given delay.
T	receive() Blocks until the next message is available.
boolean	remove(T message) Removes one instance of the given message from the queue.
void	stop() Blocks until all queued messages are delivered.

Methods inherited from class java.lang.Object

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

Constructor Detail

DelayedReceive

public DelayedReceive(TimeProvider timeProvider)

Method Detail

receive

public T receive()

Description copied from interface: Receive

Blocks until the next message is available. Returns null when the end of the message stream has been reached.

Specified by:

receive in interface Receive<T>

Returns:

The next message, or null when the end of the stream has been reached.

dispatchLater

public void dispatchLater(T message,
                 int delayValue,
                 TimeUnit delayUnits)

Dispatches the given message after the given delay.

remove

public boolean remove(T message)

Removes one instance of the given message from the queue.

Returns:

true if removed, false if not. If false is returned, the message may be currently being dispatched.

clear

public void clear()

Removes all queued messages.

stop

public void stop()

Blocks until all queued messages are delivered.

Specified by:

stop in interface Stoppable