io.vertx.ext.sync

Interface Receiver<T>

All Known Subinterfaces:

HandlerReceiverAdaptor<T>

public interface Receiver<T>

Represents a synchronous receiver of events.

Note that the `receive` methods may block the calling fiber but will not block an underlying kernel thread.

Author:

Tim Fox

Method Summary

Modifier and Type	Method and Description
T	receive() Return an event when one is available.
T	receive(long timeout) Return an event when one is available.
co.paralleluniverse.strands.channels.ReceivePort<T>	receivePort()

Method Detail

receivePort

co.paralleluniverse.strands.channels.ReceivePort<T> receivePort()

Returns:

the underlying Quasar receivePort

receive

@Suspendable
T receive()

Return an event when one is available. This method will block the fiber until one is available. No kernel thread is blocked.

Returns:

the event

receive

@Suspendable
T receive(long timeout)

Return an event when one is available. This method will block the fiber until one is available, or timeout occurs. No kernel thread is blocked.

Parameters:

timeout - the max amount of time in ms to wait for an event to be available

Returns:

the event