tidal / WampWatch

examples/thruway_internal_session_monitor/InternalSessionMonitor.php

Spacing +4 added lines, -4 removed lines

@@ -38,22 +38,22 @@
         $sessionMonitor = new SessionMonitor(new Adapter($session));
 
 
-        $sessionMonitor->on('list', function ($l) {
+        $sessionMonitor->on('list', function($l) {
             echo "\nLIST: \n";
             print_r($l);
         });
 
-        $sessionMonitor->on('join', function ($l) {
+        $sessionMonitor->on('join', function($l) {
             echo "\nJOIN: \n";
             print_r($l);
         });
 
-        $sessionMonitor->on('leave', function ($l) {
+        $sessionMonitor->on('leave', function($l) {
             echo "\nLEAVE: \n";
             print_r($l);
         });
 
-        $sessionMonitor->on('error', function ($l) {
+        $sessionMonitor->on('error', function($l) {
             echo "\nERROR: \n";
             print_r($l);
         });

examples/thruway_internal_session_monitor/client.php

Spacing +7 added lines, -7 removed lines

@@ -18,37 +18,37 @@
 $client = new Client('realm1');
 $client->addTransportProvider(new PawlTransportProvider('ws://127.0.0.1:9999/'));
 
-$client->on('open', function (ClientSession $session) {
+$client->on('open', function(ClientSession $session) {
 
     // 1) subscribe to a topic
-    $onevent = function ($args) {
+    $onevent = function($args) {
         echo "Event {$args[0]}\n";
     };
     $session->subscribe('com.myapp.hello', $onevent);
 
     // 2) publish an event
     $session->publish('com.myapp.hello', ['Hello, world from PHP!!!'], [], ['acknowledge' => true])->then(
-        function () {
+        function() {
             echo "Publish Acknowledged!\n";
         },
-        function ($error) {
+        function($error) {
             // publish failed
             echo "Publish Error {$error}\n";
         }
     );
 
     // 3) register a procedure for remoting
-    $add2 = function ($args) {
+    $add2 = function($args) {
         return $args[0] + $args[1];
     };
     $session->register('com.myapp.add2', $add2);
 
     // 4) call a remote procedure
     $session->call('com.myapp.add2', [2, 3])->then(
-        function ($res) {
+        function($res) {
             echo "Result: {$res}\n";
         },
-        function ($error) {
+        function($error) {
             echo "Call Error: {$error}\n";
         }
     );

examples/bootstrap.php

Spacing +1 added lines, -1 removed lines

@@ -3,6 +3,6 @@
 ini_set('xdebug.max_nesting_level', '200');
 if (file_exists($file = realpath(__DIR__.'/..').'/vendor/autoload.php')) {
     $loader = require_once $file;
-} else {
+}else {
     throw new RuntimeException('autoload file not found in vendor path.');
 }

examples/crossbar_session/monitor.php

Spacing +8 added lines, -8 removed lines

@@ -27,30 +27,30 @@ 
     ]
 );
 
-$connection->on('open', function (ClientSession $session) use ($connection, &$timer) {
+$connection->on('open', function(ClientSession $session) use ($connection, &$timer) {
     $sessionMonitor = new SessionMonitor(new Adapter($session));
 
 
-    $sessionMonitor->on('start', function ($l) {
+    $sessionMonitor->on('start', function($l) {
         echo "\n******** SESSION MONITOR STARTED ********\n";
         echo "\nSTART: \n";
         print_r($l);
     });
 
-    $sessionMonitor->on('list', function ($l) {
+    $sessionMonitor->on('list', function($l) {
         echo "\nLIST: \n";
         print_r($l);
     });
 
-    $sessionMonitor->on('join', function ($sessionData) {
+    $sessionMonitor->on('join', function($sessionData) {
         echo "\nJOIN: {$sessionData->session}\n";
     });
 
-    $sessionMonitor->on('leave', function ($sessionId) {
+    $sessionMonitor->on('leave', function($sessionId) {
         echo "\nLEAVE: $sessionId\n";
     });
 
-    $sessionMonitor->on('error', function ($l) {
+    $sessionMonitor->on('error', function($l) {
         echo "\nERROR: \n";
         print_r($l);
     });
@@ -59,11 +59,11 @@ 
 }
 );
 
-$connection->on('close', function ($reason) use (&$timer) {
+$connection->on('close', function($reason) use (&$timer) {
     echo "The connected has closed with reason: {$reason}\n";
 });
 
-$connection->on('error', function ($reason) {
+$connection->on('error', function($reason) {
     echo "The connected has closed with error: {$reason}\n";
 });
 

examples/crossbar_session/client.php

Spacing +3 added lines, -3 removed lines

@@ -23,19 +23,19 @@
     $loop
 );
 
-$connection->on('open', function (ClientSession $session) use ($connection, $loop, &$timer) {
+$connection->on('open', function(ClientSession $session) use ($connection, $loop, &$timer) {
     echo "\nSession established: {$session->getSessionId()}\n";
 }
 );
 
-$connection->on('close', function ($reason) use ($loop, &$timer) {
+$connection->on('close', function($reason) use ($loop, &$timer) {
     if ($timer) {
         $loop->cancelTimer($timer);
     }
     echo "The connected has closed with reason: {$reason}\n";
 });
 
-$connection->on('error', function ($reason) {
+$connection->on('error', function($reason) {
     echo "The connected has closed with error: {$reason}\n";
 });