Adding documentation for async-log

Autocommit Wed Jan 14 15:09:05 EST 2015
mxro · Jan 14, 2015 · ce5f34f · ce5f34f
1 parent 971ef28
commit ce5f34f
Show file tree

Hide file tree

Showing 3 changed files with 19 additions and 4 deletions.
diff --git a/src/main/java/de/mxro/async/properties/PropertyNode.java b/src/main/java/de/mxro/async/properties/PropertyNode.java
@@ -18,7 +18,7 @@ public interface PropertyNode {
      * 
      * @param op
      */
-    public void record(PropertyOperation op);
+    public <R> Promise<R> record(PropertyOperation<R> op);
 
     /**
      * Retrieves a property with a specified type and id.

diff --git a/src/main/java/de/mxro/async/properties/internal/SynchronizedPropertyNode.java b/src/main/java/de/mxro/async/properties/internal/SynchronizedPropertyNode.java
@@ -20,7 +20,7 @@ public class SynchronizedPropertyNode implements PropertyNode {
     private final PromiseFactory promiseFactory;
 
     @Override
-    public void record(final PropertyOperation op) {
+    public <R> Promise<R> record(final PropertyOperation<R> op) {
         accessThread.offer(new Step() {
 
             @Override

diff --git a/src/main/java/de/mxro/async/properties/internal/UnsafePropertyNode.java b/src/main/java/de/mxro/async/properties/internal/UnsafePropertyNode.java
@@ -23,8 +23,23 @@ public class UnsafePropertyNode implements PropertyNode {
     private final PropertyData data;
 
     @Override
-    public void record(final PropertyOperation op) {
-        op.perform(data);
+    public <R> Promise<R> record(final PropertyOperation<R> op) {
+
+        return PromisesCommon.createUnsafe(new Operation<R>() {
+
+            @Override
+            public void apply(final ValueCallback<R> callback) {
+                final R res;
+                try {
+                    res = op.perform(data);
+                } catch (final Throwable t) {
+                    callback.onFailure(t);
+                    return;
+                }
+                callback.onSuccess(res);
+            }
+        });
+
     }
 
     public UnsafePropertyNode(final PropertyFactory factory) {