io.sarl.sre.services.executor

Class SreConsumer<T>

java.lang.Object

io.sarl.sre.services.executor.SreExecutable

io.sarl.sre.services.executor.SreConsumer<T>

Type Parameters:

T - the type of the result.

All Implemented Interfaces:

Consumer<T>

public class SreConsumer<T>
extends SreExecutable
implements Consumer<T>

A specific SRE consumer that is catching the EarlyExitException.

Since:

0.7

Version:

io.janusproject.plugin 0.12.0 20210527-171007

Author:

Stéphane Galland

See Also:

Runnables

Maven Group Id:

io.janusproject.sre

Maven Artifact Id:

io.janusproject.plugin

Field Summary

Fields inherited from class io.sarl.sre.services.executor.SreExecutable

exception

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SreConsumer(consumer : Consumer<T>, logger : Logger) Constructor.
	SreConsumer(logger : Logger)

Method Summary

Modifier and Type	Method and Description
void	accept(t : T)
boolean	equals(obj : Object)
Consumer<T>	getWrappedConsumer() Replies the wrapped task.
int	hashCode()
protected void	internalAccept(t : T) Run the task.
String	toString()

Methods inherited from class io.sarl.sre.services.executor.SreExecutable

exceptionMessage, getException, getLogger, getRootCause, isSuccess, onError, onFinished

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.function.Consumer

andThen

Constructor Detail

SreConsumer

protected new(consumer : Consumer<T>,
              logger : Logger)

Constructor. See Runnables for creating an instance.

Parameters:

consumer - the wrapped task.

logger - the logger to use.

SreConsumer

public new(logger : Logger)

Parameters:

logger - the logger to use.

Method Detail

getWrappedConsumer

@Pure
public def getWrappedConsumer() : Consumer<T> 

Description copied from class: SreConsumer

Replies the wrapped task.

Returns:

the consumer.

internalAccept

protected def internalAccept(t : T) : void 

Description copied from class: SreConsumer

Run the task. The default implementation runs the attached Runnable.

Parameters:

t - the element to accept

accept

public final def accept(t : T) : void 

Specified by:

accept in interface Consumer<T>

toString

@Pure
public def toString() : String 

Overrides:

toString in class Object

equals

@Pure
public def equals(obj : Object) : boolean 

Overrides:

equals in class SreExecutable

hashCode

@Pure
public def hashCode() : int 

Overrides:

hashCode in class SreExecutable