hfw / socket

src/Reactor.php

Spacing +5 added lines, -5 removed lines

@@ -22,7 +22,7 @@ 
      * @param ReactiveInterface $socket
      * @return $this
      */
-    public function add (ReactiveInterface $socket) {
+    public function add(ReactiveInterface $socket) {
         $this->sockets[$socket->getId()] = $socket;
         return $this;
     }
@@ -32,14 +32,14 @@ 
      *
      * @return int
      */
-    public function count () {
+    public function count() {
         return count($this->sockets);
     }
 
     /**
      * @return SocketInterface[]
      */
-    public function getSockets () {
+    public function getSockets() {
         return $this->sockets;
     }
 
@@ -50,7 +50,7 @@ 
      * @throws Error
      * @return int Number of sockets that reacted.
      */
-    public function react ($timeout = null) {
+    public function react($timeout = null) {
         /** @var ReactiveInterface[][] $rwe */
         $rwe = [$this->sockets, [], $this->sockets];
         $count = AbstractSocket::select($rwe[0], $rwe[1], $rwe[2], $timeout);
@@ -69,7 +69,7 @@ 
      * @param int $id
      * @return $this
      */
-    public function remove ($id) {
+    public function remove($id) {
         unset($this->sockets[$id]);
         return $this;
     }

src/Error.php

Spacing +4 added lines, -4 removed lines

@@ -27,7 +27,7 @@ 
      * @param resource $resource PHP socket resource, or `null` for the global error.
      * @return int If the resource is closed or not a socket, `SOCKET_EBADF` is returned.
      */
-    public static function getLast ($resource = null) {
+    public static function getLast($resource = null) {
         if (isset($resource)) {
             if (@get_resource_type($resource) !== 'Socket') {
                 return SOCKET_EBADF;
@@ -53,7 +53,7 @@ 
      *     PHP's last suppressed warning is used for the message.
      *
      */
-    public function __construct ($subject = null, $fallback = 0) {
+    public function __construct($subject = null, $fallback = 0) {
         if (is_int($subject)) {
             $errno = $subject;
         }
@@ -73,7 +73,7 @@ 
     /**
      * @return mixed
      */
-    public function getExtra () {
+    public function getExtra() {
         return $this->extra;
     }
 
@@ -81,7 +81,7 @@ 
      * @param mixed $extra
      * @return $this
      */
-    public function setExtra ($extra) {
+    public function setExtra($extra) {
         $this->extra = $extra;
         return $this;
     }

src/AbstractClient.php

Spacing +5 added lines, -5 removed lines

@@ -14,7 +14,7 @@ 
      *
      * @return string
      */
-    public function __toString () {
+    public function __toString() {
         try {
             return implode(':', $this->getPeerName());
         }
@@ -38,7 +38,7 @@ 
      * @throws Error
      * @return $this
      */
-    public function connect ($address, $port = 0) {
+    public function connect($address, $port = 0) {
         if (!@socket_connect($this->resource, $address, $port)) {
             // ignore expected errors for non-blocking connections
             $errno = Error::getLast($this->resource);
@@ -58,7 +58,7 @@ 
      * @throws Error
      * @return array Address and port at indices `0` and `1`.
      */
-    public function getPeerName () {
+    public function getPeerName() {
         if ($this->domain === AF_UNIX) {
             return [$this->getOption(self::SO_PEERCRED), 0];
         }
@@ -80,7 +80,7 @@ 
      * @throws Error
      * @return int Total bytes sent.
      */
-    public function send ($data, $flags = 0) {
+    public function send($data, $flags = 0) {
         $count = @socket_send($this->resource, $data, PHP_INT_MAX, $flags);
         if ($count === false) {
             $error = new Error($this->resource); // reliable errno
@@ -99,7 +99,7 @@ 
      * @throws Error Total bytes sent is set as the error's extra data.
      * @return $this
      */
-    public function write ($data) {
+    public function write($data) {
         $data = (string)$data;
         $length = strlen($data);
         $total = 0;

src/DatagramServer.php

Spacing +2 added lines, -2 removed lines

@@ -12,7 +12,7 @@ 
      *
      * @return int
      */
-    final public static function getType () {
+    final public static function getType() {
         return SOCK_DGRAM;
     }
 
@@ -30,7 +30,7 @@ 
      * @throws Error
      * @return string
      */
-    public function recv ($length, $flags = 0, &$name = null, &$port = 0) {
+    public function recv($length, $flags = 0, &$name = null, &$port = 0) {
         $count = @socket_recvfrom($this->resource, $data, $length, $flags, $name, $port);
         if ($count === false) {
             $error = new Error($this->resource, SOCKET_EOPNOTSUPP);

src/DatagramClient.php

Spacing +1 added lines, -1 removed lines

@@ -12,7 +12,7 @@
      *
      * @return int
      */
-    final public static function getType () {
+    final public static function getType() {
         return SOCK_DGRAM;
     }
 

src/WebSocketFrame.php

Spacing +13 added lines, -13 removed lines

@@ -25,7 +25,7 @@ 
      * @param bool $final
      * @return string
      */
-    public static function pack (string $payload, int $opCode = self::OP_TEXT, bool $final = true): string {
+    public static function pack(string $payload, int $opCode = self::OP_TEXT, bool $final = true): string {
         $frame = chr(0x80 | $opCode);
         $len = strlen($payload);
         if ($len > 65535) {
@@ -39,14 +39,14 @@ 
         else {
             $frame .= chr($len);
         }
-        return $frame . $payload;
+        return $frame.$payload;
     }
 
-    public function __construct (string $data) {
+    public function __construct(string $data) {
         $this->data = $data;
     }
 
-    final public function getLength () {
+    final public function getLength() {
         switch ($char = ord($this->data[1]) & 0x7f) {
             case 127: // big-endian long-long
                 return unpack('J', substr($this->data, 2, 8));
@@ -60,7 +60,7 @@ 
     /**
      * @return int[]
      */
-    final public function getMask () {
+    final public function getMask() {
         if ($this->isMasked()) {
             switch (ord($this->data[1]) & 0x7f) {
                 case 127:
@@ -74,11 +74,11 @@ 
         return [0, 0, 0, 0];
     }
 
-    final public function getOpCode (): int {
+    final public function getOpCode(): int {
         return ord($this->data[0]) & 0x0f;
     }
 
-    final public function getPayload (): string {
+    final public function getPayload(): string {
         $length = $this->getLength();
         if ($length === 0) {
             return '';
@@ -102,27 +102,27 @@ 
         return $decoded;
     }
 
-    final public function isBinary (): bool {
+    final public function isBinary(): bool {
         return $this->getOpCode() === self::OP_BINARY;
     }
 
-    final public function isClose (): bool {
+    final public function isClose(): bool {
         return $this->getOpCode() === self::OP_CLOSE;
     }
 
-    final public function isFinal (): bool {
+    final public function isFinal(): bool {
         return (bool)(ord($this->data[0]) & 0x80);
     }
 
-    final public function isMasked (): bool {
+    final public function isMasked(): bool {
         return (bool)(ord($this->data[1]) & 0x80);
     }
 
-    final public function isPong (): bool {
+    final public function isPong(): bool {
         return $this->getOpCode() === self::OP_PONG;
     }
 
-    final public function isText (): bool {
+    final public function isText(): bool {
         return $this->getOpCode() === self::OP_TEXT;
     }
 

src/ReactiveInterface.php

Spacing +2 added lines, -2 removed lines

@@ -14,13 +14,13 @@
      *
      * @return void
      */
-    public function onOutOfBand ();
+    public function onOutOfBand();
 
     /**
      * Called by the reactor when the socket has readable data.
      *
      * @return void
      */
-    public function onReadable ();
+    public function onReadable();
 
 }
\ No newline at end of file

src/SocketInterface.php

Spacing +5 added lines, -5 removed lines

@@ -42,34 +42,34 @@
      *
      * @return int `SOCK_*`
      */
-    public static function getType ();
+    public static function getType();
 
     /**
      * Returns the address family constant of the socket.
      *
      * @return int `AF_*`
      */
-    public function getDomain ();
+    public function getDomain();
 
     /**
      * Returns the underlying socket resource as an integer.
      *
      * @return int
      */
-    public function getId ();
+    public function getId();
 
     /**
      * Returns the protocol constant used by the socket.
      *
      * @return int
      */
-    public function getProtocol ();
+    public function getProtocol();
 
     /**
      * Returns the underlying socket resource.
      *
      * @return resource
      */
-    public function getResource ();
+    public function getResource();
 
 }
\ No newline at end of file

src/AbstractServer.php

Spacing +2 added lines, -2 removed lines

@@ -14,7 +14,7 @@ 
      *
      * @return string
      */
-    public function __toString () {
+    public function __toString() {
         try {
             return implode(':', $this->getSockName());
         }
@@ -36,7 +36,7 @@ 
      * @throws Error
      * @return $this
      */
-    public function bind (string $address, int $port = 0) {
+    public function bind(string $address, int $port = 0) {
         if (!@socket_bind($this->resource, $address, $port)) {
             throw new Error($this->resource, SOCKET_EOPNOTSUPP);
         }