MessageStream.ResultWaiter (org.codehaus.gpars)

groovyx.gpars.actor.impl.MessageStream.ResultWaiter

Represents a pending request for a reply from an actor.
Parameters:
- The type of expected reply message

Field Summary

Fields
Modifiers	Name	Description
`private boolean`	`isSet`
`private static long`	`serialVersionUID`
`private java.lang.Object`	`value`	Holds a reference to the calling thread, while waiting, and the received reply message, once it has arrived.

Inherited fields
Fields inherited from class	Fields
`class MessageStream`	`serialVersionUID`
`class WithSerialId`	`serialHandle, serialVersionUID`

Constructor Summary

Constructors
Constructor and description
`private MessageStream.ResultWaiter ()`

Methods Summary

Methods
Type	Name and description
`V`	`getResult()` Retrieves the response blocking until a message arrives
`java.lang.Object`	`getResult(long timeout, java.util.concurrent.TimeUnit units)` Retrieves the response blocking until a message arrives
`void`	`onDeliveryError(java.lang.Object msg)` Handle cases when the message sent to the actor doesn't get delivered
`private void`	`rethrowException()`
`MessageStream`	`send(java.lang.Object message)` Accepts the message as a reply and wakes up the sleeping thread.

Inherited Methods Summary

Inherited Methods
Methods inherited from class	Name
`class MessageStream`	`call, getRemoteClass, leftShift, reInterrupt, send, send, send, sendAndWait, sendAndWait, sendAndWait`
`class WithSerialId`	`createRemoteHandle, getOrCreateSerialHandle, getRemoteClass, writeReplace`
`class java.lang.Object`	`java.lang.Object#wait(), java.lang.Object#wait(long, int), java.lang.Object#wait(long), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll()`

- Field Detail
  - private boolean isSet
  - private static final long serialVersionUID
  - private java.lang.Object value
    
    Holds a reference to the calling thread, while waiting, and the received reply message, once it has arrived.
- Constructor Detail
  - private MessageStream.ResultWaiter()
- Method Detail
  - @java.lang.SuppressWarnings("unchecked") public V getResult()
    
    Retrieves the response blocking until a message arrives
    throws:
    InterruptedException If the thread gets interrupted
    
    Returns:
    The received message
  - public java.lang.Object getResult(long timeout, java.util.concurrent.TimeUnit units)
    
    Retrieves the response blocking until a message arrives
    throws:
    InterruptedException If the thread gets interrupted
    
    Returns:
    The received message
    Parameters:
    timeout - How long to wait
    units - Unit for the timeout
  - @java.lang.SuppressWarnings("unused") // TODO: Eclipse requires this to be tagged as unused. public void onDeliveryError(java.lang.Object msg)
    
    Handle cases when the message sent to the actor doesn't get delivered
    Parameters:
    msg - The message that failed to get delivered
  - private void rethrowException()
  - @java.lang.Override public MessageStream send(java.lang.Object message)
    
    Accepts the message as a reply and wakes up the sleeping thread.
    Returns:
    this
    Parameters:
    message - message to send

Summary:
Field
Constructor
Method

| Detail:
Field
Constructor
Method

[Java] Class ResultWaiter<V>

Field Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Field Detail

private boolean isSet

private static final long serialVersionUID

private java.lang.Object value

Constructor Detail

private MessageStream.ResultWaiter()

Method Detail

@java.lang.SuppressWarnings("unchecked") public V getResult()

public java.lang.Object getResult(long timeout, java.util.concurrent.TimeUnit units)

@java.lang.SuppressWarnings("unused") // TODO: Eclipse requires this to be tagged as unused. public void onDeliveryError(java.lang.Object msg)

private void rethrowException()

@java.lang.Override public MessageStream send(java.lang.Object message)