Fixes #68 : Added a sleep time after a message is sent

Wisembly · Sep 8, 2014 · 61f7eb8 · 61f7eb8
1 parent e61dbb5
commit 61f7eb8
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 3 deletions.
diff --git a/src/Engine/AbstractSocketIO.php b/src/Engine/AbstractSocketIO.php
@@ -200,6 +200,7 @@ protected function getDefaultOptions()
  {
  return ['context' => [],
  'debug' => false,
+ 'wait' => 100*1000,
  'timeout' => ini_get("default_socket_timeout")];
  }
 }

diff --git a/src/Engine/SocketIO/Version0X.php b/src/Engine/SocketIO/Version0X.php
@@ -105,7 +105,12 @@ public function write($code, $message = null)
  }
 
  $payload = new Encoder($code . ':::' . $message, Encoder::OPCODE_TEXT, true);
- return fwrite($this->stream, (string) $payload);
+ $bytes = fwrite($this->stream, (string) $payload);
+
+ // wait a little bit of time after this message was sent
+ usleep($this->options['wait']);
+
+ return $bytes;
  }
 
  /** {@inheritDoc} */

diff --git a/src/Engine/SocketIO/Version1X.php b/src/Engine/SocketIO/Version1X.php
@@ -81,7 +81,7 @@ public function close()
  /** {@inheritDoc} */
  public function emit($event, array $args)
  {
- $this->write(EngineInterface::MESSAGE, static::EVENT . json_encode([$event, $args]));
+ return $this->write(EngineInterface::MESSAGE, static::EVENT . json_encode([$event, $args]));
  }
 
  /** {@inheritDoc} */
@@ -96,7 +96,12 @@ public function write($code, $message = null)
  }
 
  $payload = new Encoder($code . $message, Encoder::OPCODE_TEXT, true);
- return fwrite($this->stream, (string) $payload);
+ $bytes = fwrite($this->stream, (string) $payload);
+
+ // wait a little bit of time after this message was sent
+ usleep((int) $this->options['wait']);
+
+ return $bytes;
  }
 
  /** {@inheritDoc} */