org.codehaus.gpars

groovyx.gpars.dataflow.impl
[Java] Class ThenMessagingRunnable

java.lang.Object
  groovy.lang.GroovyObjectSupport
      groovy.lang.Closure
          groovyx.gpars.MessagingRunnable
              groovyx.gpars.dataflow.impl.ThenMessagingRunnable

public class ThenMessagingRunnable
extends MessagingRunnable

Authors:
Vaclav Pech


Field Summary
private groovy.lang.Closure closure

private groovy.lang.Closure errorHandler

private DataflowVariable result

 
Fields inherited from class MessagingRunnable
MESSAGING_RUNNABLE_NEED_EXACTLY_ONE_ARGUMENT_TO_RUN, PARAMETER_TYPES, serialVersionUID
 
Fields inherited from class groovy.lang.Closure
OWNER_FIRST, DELEGATE_FIRST, OWNER_ONLY, DELEGATE_ONLY, TO_SELF, DONE, SKIP, IDENTITY
 
Constructor Summary
ThenMessagingRunnable(DataflowVariable result, groovy.lang.Closure closure)

ThenMessagingRunnable(DataflowVariable result, groovy.lang.Closure closure, groovy.lang.Closure errorHandler)

 
Method Summary
protected void doRun(java.lang.Object argument)

private boolean shallHandle(groovy.lang.Closure errorHandler, java.lang.Throwable e)

 
Methods inherited from class MessagingRunnable
call, call, call, doRun, getMaximumNumberOfParameters, getParameterTypes
 
Methods inherited from class groovy.lang.Closure
groovy.lang.Closure#run(), groovy.lang.Closure#setProperty(java.lang.String, java.lang.Object), groovy.lang.Closure#getProperty(java.lang.String), groovy.lang.Closure#clone(), groovy.lang.Closure#getParameterTypes(), groovy.lang.Closure#setDelegate(java.lang.Object), groovy.lang.Closure#getOwner(), groovy.lang.Closure#leftShift(java.lang.Object), groovy.lang.Closure#leftShift(groovy.lang.Closure), groovy.lang.Closure#rightShift(groovy.lang.Closure), groovy.lang.Closure#call(java.lang.Object), groovy.lang.Closure#call([Ljava.lang.Object;), groovy.lang.Closure#call(), groovy.lang.Closure#setResolveStrategy(int), groovy.lang.Closure#getMaximumNumberOfParameters(), groovy.lang.Closure#getResolveStrategy(), groovy.lang.Closure#getThisObject(), groovy.lang.Closure#getDelegate(), groovy.lang.Closure#getDirective(), groovy.lang.Closure#setDirective(int), groovy.lang.Closure#isCase(java.lang.Object), groovy.lang.Closure#asWritable(), groovy.lang.Closure#curry([Ljava.lang.Object;), groovy.lang.Closure#curry(java.lang.Object), groovy.lang.Closure#rcurry(java.lang.Object), groovy.lang.Closure#rcurry([Ljava.lang.Object;), groovy.lang.Closure#ncurry(int, [Ljava.lang.Object;), groovy.lang.Closure#ncurry(int, java.lang.Object), groovy.lang.Closure#memoize(), groovy.lang.Closure#memoizeAtMost(int), groovy.lang.Closure#memoizeAtLeast(int), groovy.lang.Closure#memoizeBetween(int, int), groovy.lang.Closure#trampoline(), groovy.lang.Closure#trampoline([Ljava.lang.Object;), groovy.lang.Closure#dehydrate(), groovy.lang.Closure#rehydrate(java.lang.Object, java.lang.Object, java.lang.Object), groovy.lang.Closure#getMetaClass(), groovy.lang.Closure#setMetaClass(groovy.lang.MetaClass), groovy.lang.Closure#invokeMethod(java.lang.String, java.lang.Object), groovy.lang.Closure#wait(long), groovy.lang.Closure#wait(), groovy.lang.Closure#wait(long, int), groovy.lang.Closure#equals(java.lang.Object), groovy.lang.Closure#toString(), groovy.lang.Closure#hashCode(), groovy.lang.Closure#getClass(), groovy.lang.Closure#notify(), groovy.lang.Closure#notifyAll()
 

Field Detail

closure

private final groovy.lang.Closure closure


errorHandler

private final groovy.lang.Closure errorHandler


result

private final DataflowVariable result


 
Constructor Detail

ThenMessagingRunnable

public ThenMessagingRunnable(DataflowVariable result, groovy.lang.Closure closure)


ThenMessagingRunnable

public ThenMessagingRunnable(DataflowVariable result, groovy.lang.Closure closure, groovy.lang.Closure errorHandler)


 
Method Detail

doRun

@Override
protected void doRun(java.lang.Object argument)


shallHandle

private boolean shallHandle(groovy.lang.Closure errorHandler, java.lang.Throwable e)


 

Copyright © 2008–2012 Václav Pech. All Rights Reserved.