svn commit: r1435613 - /ode/trunk/jacob/src/test/java/org/apache/ode/jacob/examples/synch/SynchPrinter.java

[ha...@apache.org]

Author: hadrian
Date: Sat Jan 19 17:32:53 2013
New Revision: 1435613

URL: http://svn.apache.org/viewvc?rev=1435613&view=rev
Log:
Refactor example per Tammo's suggestion

Modified:
    ode/trunk/jacob/src/test/java/org/apache/ode/jacob/examples/synch/SynchPrinter.java

Modified: ode/trunk/jacob/src/test/java/org/apache/ode/jacob/examples/synch/SynchPrinter.java
URL: http://svn.apache.org/viewvc/ode/trunk/jacob/src/test/java/org/apache/ode/jacob/examples/synch/SynchPrinter.java?rev=1435613&r1=1435612&r2=1435613&view=diff
==============================================================================
--- ode/trunk/jacob/src/test/java/org/apache/ode/jacob/examples/synch/SynchPrinter.java (original)
+++ ode/trunk/jacob/src/test/java/org/apache/ode/jacob/examples/synch/SynchPrinter.java Sat Jan 19 17:32:53 2013
@@ -61,10 +61,14 @@ public class SynchPrinter {
         public void run() {
             final SynchPrint p = newChannel(SynchPrint.class);
             instance(new SystemPrinter(p));
-            printer(p).print("1").then().print("2").then().print("3").done().run();
+            dudeWhoStoleMyCar(p)
+                .order("1")
+                .and().then().order("2")
+                .and().then().order("3")
+                .and().no().andthen();
         }
 
-        public static PrinterProcess printer(SynchPrint p) {
+        public static PrinterProcess dudeWhoStoleMyCar(SynchPrint p) {
             return new PrinterProcess(p);
         }
 
@@ -81,16 +85,23 @@ public class SynchPrinter {
                 printer = p;
                 this.prev = prev;
             }
-            public PrinterProcess print(String message) {
+            public PrinterProcess order(String message) {
                 this.message = message;
                 return this;
             }
+            public PrinterProcess and() {
+                // noop
+                return this;
+            }
             public PrinterProcess then() {
                 next = new PrinterProcess(printer, this);
                 return next;
             }
-            public PrinterProcess done() {
-                return prev != null ? prev.done() : this;
+            public PrinterProcess no() {
+                return prev != null ? prev.no() : this;
+            }
+            public void andthen() {
+                run();
             }
 
             @Override