Index: tests/concurrency/actors/dynamic.cfa
===================================================================
--- tests/concurrency/actors/dynamic.cfa	(revision 05956d21b283440532f252a1c679dc968168b993)
+++ tests/concurrency/actors/dynamic.cfa	(revision 77fd9fe2224caa2c11720d1aa2c77988cc5643ba)
@@ -28,5 +28,5 @@
     derived_actor * d_actor = alloc();
     (*d_actor){};
-    *d_actor << *d_msg;
+    *d_actor | *d_msg;
     return Delete;
 }
@@ -58,5 +58,5 @@
     derived_actor * d_actor = alloc();
     (*d_actor){};
-    *d_actor << *d_msg;
+    *d_actor | *d_msg;
 
     printf("stopping\n");
Index: tests/concurrency/actors/executor.cfa
===================================================================
--- tests/concurrency/actors/executor.cfa	(revision 05956d21b283440532f252a1c679dc968168b993)
+++ tests/concurrency/actors/executor.cfa	(revision 77fd9fe2224caa2c11720d1aa2c77988cc5643ba)
@@ -28,5 +28,5 @@
     if ( recs % Batch == 0 ) {
         for ( i; Batch ) {
-            gstart[sends % Set] << shared_msg;
+            gstart[sends % Set] | shared_msg;
             sends += 1;
         }
@@ -94,5 +94,5 @@
 
 	for ( i; Actors ) {
-		actors[i] << shared_msg;
+		actors[i] | shared_msg;
 	} // for
 
Index: tests/concurrency/actors/inherit.cfa
===================================================================
--- tests/concurrency/actors/inherit.cfa	(revision 05956d21b283440532f252a1c679dc968168b993)
+++ tests/concurrency/actors/inherit.cfa	(revision 77fd9fe2224caa2c11720d1aa2c77988cc5643ba)
@@ -38,6 +38,6 @@
         Server2 * s2 = alloc();
         (*s2){};
-        *s << *dm;
-        *s2 << *dm2;
+        *s | *dm;
+        *s2 | *dm2;
         stop_actor_system();
     }
@@ -49,6 +49,6 @@
         D_msg2 * dm2 = alloc();
         (*dm2){};
-        s[0] << *dm;
-        s[1] << *dm2;
+        s[0] | *dm;
+        s[1] | *dm2;
         stop_actor_system();
     }
Index: tests/concurrency/actors/inline.cfa
===================================================================
--- tests/concurrency/actors/inline.cfa	(revision 05956d21b283440532f252a1c679dc968168b993)
+++ tests/concurrency/actors/inline.cfa	(revision 77fd9fe2224caa2c11720d1aa2c77988cc5643ba)
@@ -41,5 +41,5 @@
         d_msg * dm = alloc();
         (*dm){ 42, 2423 };
-        da << *dm;
+        da | *dm;
         stop_actor_system();                                // waits until actors finish
     }
@@ -52,5 +52,5 @@
         message * mg = &dm;
         virtual_dtor * v = &dm;
-        da << dm;
+        da | dm;
         stop_actor_system();                                // waits until actors finish
     }
Index: tests/concurrency/actors/matrix.cfa
===================================================================
--- tests/concurrency/actors/matrix.cfa	(revision 05956d21b283440532f252a1c679dc968168b993)
+++ tests/concurrency/actors/matrix.cfa	(revision 77fd9fe2224caa2c11720d1aa2c77988cc5643ba)
@@ -105,5 +105,5 @@
 
 	for ( unsigned int r = 0; r < xr; r += 1 ) {
-		actors[r] << messages[r];
+		actors[r] | messages[r];
 	} // for
 
Index: tests/concurrency/actors/pingpong.cfa
===================================================================
--- tests/concurrency/actors/pingpong.cfa	(revision 05956d21b283440532f252a1c679dc968168b993)
+++ tests/concurrency/actors/pingpong.cfa	(revision 77fd9fe2224caa2c11720d1aa2c77988cc5643ba)
@@ -25,5 +25,5 @@
     allocation retval = Nodelete;
     if ( msg.count == times ) retval = Finished;
-    *po << msg;
+    *po | msg;
     return retval;
 }
@@ -35,5 +35,5 @@
     allocation retval = Nodelete;
     if ( msg.count == times ) retval = Finished;
-    *pi << msg;
+    *pi | msg;
     return retval;
 }
@@ -53,5 +53,5 @@
     pi = &pi_actor;
     p_msg m;
-    pi_actor << m;
+    pi_actor | m;
     stop_actor_system();
 
Index: tests/concurrency/actors/poison.cfa
===================================================================
--- tests/concurrency/actors/poison.cfa	(revision 05956d21b283440532f252a1c679dc968168b993)
+++ tests/concurrency/actors/poison.cfa	(revision 77fd9fe2224caa2c11720d1aa2c77988cc5643ba)
@@ -18,5 +18,5 @@
         Server s[10];
         for ( i; 10 ) {
-            s[i] << finished_msg;
+            s[i] | finished_msg;
         }
         stop_actor_system();
@@ -29,5 +29,5 @@
             Server * s = alloc();
             (*s){};
-            (*s) << delete_msg;
+            (*s) | delete_msg;
         }
         stop_actor_system();
@@ -39,5 +39,5 @@
         Server s[10];
         for ( i; 10 )
-            s[i] << destroy_msg;
+            s[i] | destroy_msg;
         stop_actor_system();
         for ( i; 10 )
Index: tests/concurrency/actors/static.cfa
===================================================================
--- tests/concurrency/actors/static.cfa	(revision 05956d21b283440532f252a1c679dc968168b993)
+++ tests/concurrency/actors/static.cfa	(revision 77fd9fe2224caa2c11720d1aa2c77988cc5643ba)
@@ -25,5 +25,5 @@
     }
     msg.cnt++;
-    receiver << msg;
+    receiver | msg;
     return Nodelete;
 }
@@ -55,5 +55,5 @@
     derived_actor actor;
 
-    actor << msg;
+    actor | msg;
 
     printf("stopping\n");
Index: tests/concurrency/actors/types.cfa
===================================================================
--- tests/concurrency/actors/types.cfa	(revision 05956d21b283440532f252a1c679dc968168b993)
+++ tests/concurrency/actors/types.cfa	(revision 77fd9fe2224caa2c11720d1aa2c77988cc5643ba)
@@ -72,5 +72,5 @@
     b.num = 1;
     c.num = 2;
-    a << b << c;
+    a | b | c;
     stop_actor_system();
 
@@ -80,6 +80,6 @@
     d_msg d_ac2_msg;
     d_ac2_msg.num = 3;
-    d_ac2_0 << d_ac2_msg;
-    d_ac2_1 << d_ac2_msg;
+    d_ac2_0 | d_ac2_msg;
+    d_ac2_1 | d_ac2_msg;
     stop_actor_system();
 
@@ -93,6 +93,6 @@
         d_msg d_ac23_msg;
         d_ac23_msg.num = 4;
-        d_ac3_0 << d_ac23_msg;
-        d_ac2_2 << d_ac23_msg;
+        d_ac3_0 | d_ac23_msg;
+        d_ac2_2 | d_ac23_msg;
         stop_actor_system();
     } // RAII to clean up executor
@@ -107,5 +107,5 @@
         b1.num = -1;
         c2.num = 5;
-        a3 << b1 << c2;
+        a3 | b1 | c2;
         stop_actor_system();
     } // RAII to clean up executor
@@ -120,5 +120,5 @@
         b1.num = -1;
         c2.num = 5;
-        a4 << b1 << c2;
+        a4 | b1 | c2;
         stop_actor_system();
     } // RAII to clean up executor