Package io.manebot.virtual
Class SynchronousTransfer<C,S,E extends java.lang.Exception>
- java.lang.Object
-
- io.manebot.virtual.Transfer<C,S,E>
-
- io.manebot.virtual.SynchronousTransfer<C,S,E>
-
- All Implemented Interfaces:
ThrowingFunction<C,S,E>
,java.lang.Runnable
,java.util.function.Function<C,S>
public class SynchronousTransfer<C,S,E extends java.lang.Exception> extends Transfer<C,S,E> implements java.lang.Runnable
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description class
SynchronousTransfer.Message
-
Constructor Summary
Constructors Constructor Description SynchronousTransfer(java.lang.Class<E> exceptionClass, ThrowingFunction<C,S,E> function)
-
Method Summary
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface io.manebot.lambda.ThrowingFunction
apply
-
-
-
-
Constructor Detail
-
SynchronousTransfer
public SynchronousTransfer(java.lang.Class<E> exceptionClass, ThrowingFunction<C,S,E> function)
-
-
Method Detail
-
applyChecked
public S applyChecked(C object) throws E extends java.lang.Exception
Sends a resource into the synchronous transfer.- Specified by:
applyChecked
in interfaceThrowingFunction<C,S,E extends java.lang.Exception>
- Overrides:
applyChecked
in classTransfer<C,S,E extends java.lang.Exception>
- Parameters:
object
- resource to place into the queue.- Returns:
- response object.
- Throws:
java.lang.RuntimeException
- if execution fails.E extends java.lang.Exception
-
get
public S get(C object, int timeoutMillis) throws java.util.concurrent.ExecutionException, java.util.concurrent.TimeoutException
- Throws:
java.util.concurrent.ExecutionException
java.util.concurrent.TimeoutException
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
-
-