diff --git a/src/main/java/org/syndicate_lang/actors/AbstractProxy.java b/src/main/java/org/syndicate_lang/actors/AbstractProxy.java index ea0f0b3..10bfb09 100644 --- a/src/main/java/org/syndicate_lang/actors/AbstractProxy.java +++ b/src/main/java/org/syndicate_lang/actors/AbstractProxy.java @@ -27,12 +27,12 @@ public abstract class AbstractProxy implements InvocationHandler { } @Override - public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { + public Object invoke(Object proxy, Method method, Object[] args) { if (method.equals(toStringMethod)) { return this._ref.toString(); } return dispatch(method, args); } - abstract Object dispatch(Method method, Object[] args) throws Throwable; + abstract Object dispatch(Method method, Object[] args); } diff --git a/src/main/java/org/syndicate_lang/actors/ActorTerminated.java b/src/main/java/org/syndicate_lang/actors/ActorTerminated.java index 99a7729..69d26dc 100644 --- a/src/main/java/org/syndicate_lang/actors/ActorTerminated.java +++ b/src/main/java/org/syndicate_lang/actors/ActorTerminated.java @@ -1,7 +1,7 @@ package org.syndicate_lang.actors; public class ActorTerminated extends Exception { - private Actor _actor; + private final Actor _actor; public ActorTerminated(Actor actor) { super("Actor terminated: " + actor, actor.getExitReason()); diff --git a/src/main/java/org/syndicate_lang/actors/AsyncProxy.java b/src/main/java/org/syndicate_lang/actors/AsyncProxy.java index d8cc780..3d62f70 100644 --- a/src/main/java/org/syndicate_lang/actors/AsyncProxy.java +++ b/src/main/java/org/syndicate_lang/actors/AsyncProxy.java @@ -9,7 +9,7 @@ public class AsyncProxy extends AbstractProxy { } @Override - public Object dispatch(Method method, Object[] args) throws Throwable { + public Object dispatch(Method method, Object[] args) { if (method.getReturnType().equals(void.class)) { this._ref.async((v) -> { try { diff --git a/src/main/java/org/syndicate_lang/actors/BrokenPromise.java b/src/main/java/org/syndicate_lang/actors/BrokenPromise.java index 8a841e4..f20a668 100644 --- a/src/main/java/org/syndicate_lang/actors/BrokenPromise.java +++ b/src/main/java/org/syndicate_lang/actors/BrokenPromise.java @@ -1,7 +1,7 @@ package org.syndicate_lang.actors; public class BrokenPromise extends RuntimeException { - private Promise _promise; + private final Promise _promise; public BrokenPromise(Promise promise) { super(promise.getReason()); diff --git a/src/main/java/org/syndicate_lang/actors/PeriodicTimer.java b/src/main/java/org/syndicate_lang/actors/PeriodicTimer.java index 0722d16..883d2f6 100644 --- a/src/main/java/org/syndicate_lang/actors/PeriodicTimer.java +++ b/src/main/java/org/syndicate_lang/actors/PeriodicTimer.java @@ -3,7 +3,7 @@ package org.syndicate_lang.actors; import java.util.concurrent.ScheduledFuture; public class PeriodicTimer { - private ScheduledFuture _future; + private final ScheduledFuture _future; protected PeriodicTimer(ScheduledFuture future) { this._future = future; diff --git a/src/main/java/org/syndicate_lang/actors/Promise.java b/src/main/java/org/syndicate_lang/actors/Promise.java index 8a335ed..2510e9b 100644 --- a/src/main/java/org/syndicate_lang/actors/Promise.java +++ b/src/main/java/org/syndicate_lang/actors/Promise.java @@ -5,7 +5,6 @@ import java.util.List; import java.util.concurrent.*; import java.util.function.Consumer; import java.util.function.Function; -import java.util.function.Supplier; public class Promise implements Future { diff --git a/src/main/java/org/syndicate_lang/actors/Remote.java b/src/main/java/org/syndicate_lang/actors/Remote.java index 0076aa5..7da734a 100644 --- a/src/main/java/org/syndicate_lang/actors/Remote.java +++ b/src/main/java/org/syndicate_lang/actors/Remote.java @@ -1,8 +1,5 @@ package org.syndicate_lang.actors; -import java.lang.reflect.InvocationHandler; -import java.lang.reflect.InvocationTargetException; -import java.lang.reflect.Method; import java.lang.reflect.Proxy; import java.util.function.Consumer; import java.util.function.Function; diff --git a/src/main/java/org/syndicate_lang/actors/SyncProxy.java b/src/main/java/org/syndicate_lang/actors/SyncProxy.java index f9b1b8e..23e8bd8 100644 --- a/src/main/java/org/syndicate_lang/actors/SyncProxy.java +++ b/src/main/java/org/syndicate_lang/actors/SyncProxy.java @@ -1,6 +1,5 @@ package org.syndicate_lang.actors; -import java.lang.reflect.InvocationHandler; import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; @@ -10,7 +9,7 @@ public class SyncProxy extends AbstractProxy { } @Override - public Object dispatch(Method method, Object[] args) throws Throwable { + public Object dispatch(Method method, Object[] args) { return this._ref.sync((v) -> { try { return method.invoke(v, args); diff --git a/src/main/java/org/syndicate_lang/actors/ThrowingSupplier.java b/src/main/java/org/syndicate_lang/actors/ThrowingSupplier.java index 81bf841..efc8323 100644 --- a/src/main/java/org/syndicate_lang/actors/ThrowingSupplier.java +++ b/src/main/java/org/syndicate_lang/actors/ThrowingSupplier.java @@ -1,5 +1,5 @@ package org.syndicate_lang.actors; public interface ThrowingSupplier { - public T get() throws Throwable; + T get() throws Throwable; } diff --git a/src/test/erlang/.gitignore b/src/test/erlang/.gitignore new file mode 100644 index 0000000..fa4d3fb --- /dev/null +++ b/src/test/erlang/.gitignore @@ -0,0 +1 @@ +ring.beam diff --git a/src/test/java/org/syndicate_lang/actors/example/example1/IValueHolder.java b/src/test/java/org/syndicate_lang/actors/example/example1/IValueHolder.java index c43b337..ceef0e7 100644 --- a/src/test/java/org/syndicate_lang/actors/example/example1/IValueHolder.java +++ b/src/test/java/org/syndicate_lang/actors/example/example1/IValueHolder.java @@ -1,6 +1,6 @@ package org.syndicate_lang.actors.example.example1; public interface IValueHolder { - public T get(); - public void set(T newValue); + T get(); + void set(T newValue); } diff --git a/src/test/java/org/syndicate_lang/actors/example/example1/ValueHolder.java b/src/test/java/org/syndicate_lang/actors/example/example1/ValueHolder.java index a90b349..8cea1de 100644 --- a/src/test/java/org/syndicate_lang/actors/example/example1/ValueHolder.java +++ b/src/test/java/org/syndicate_lang/actors/example/example1/ValueHolder.java @@ -1,7 +1,5 @@ package org.syndicate_lang.actors.example.example1; -import java.util.concurrent.Future; - public class ValueHolder implements IValueHolder { private T value; diff --git a/src/test/java/org/syndicate_lang/actors/example/example2/Forwarder.java b/src/test/java/org/syndicate_lang/actors/example/example2/Forwarder.java index 38ae6fa..0f4f7ae 100644 --- a/src/test/java/org/syndicate_lang/actors/example/example2/Forwarder.java +++ b/src/test/java/org/syndicate_lang/actors/example/example2/Forwarder.java @@ -1,7 +1,6 @@ package org.syndicate_lang.actors.example.example2; import org.syndicate_lang.actors.Remote; -// import java.util.Random; public class Forwarder implements IForwarder { private final Remote _main; diff --git a/src/test/java/org/syndicate_lang/actors/example/example2/IForwarder.java b/src/test/java/org/syndicate_lang/actors/example/example2/IForwarder.java index 7e8f331..a004187 100644 --- a/src/test/java/org/syndicate_lang/actors/example/example2/IForwarder.java +++ b/src/test/java/org/syndicate_lang/actors/example/example2/IForwarder.java @@ -1,6 +1,5 @@ package org.syndicate_lang.actors.example.example2; -import org.syndicate_lang.actors.Actor; import org.syndicate_lang.actors.Remote; public interface IForwarder {