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 classSynchronousTransfer.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:
applyCheckedin interfaceThrowingFunction<C,S,E extends java.lang.Exception>- Overrides:
applyCheckedin 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.ExecutionExceptionjava.util.concurrent.TimeoutException
-
run
public void run()
- Specified by:
runin interfacejava.lang.Runnable
-
-