hfw / socket

src/AbstractSocket.php

Spacing +29 added lines, -29 removed lines

@@ -40,7 +40,7 @@ 
      * @return static
      * @throws Error
      */
-    public static function create ($domain = AF_INET, ...$extra) {
+    public static function create($domain = AF_INET, ...$extra) {
         if (!$resource = @socket_create($domain, static::getType(), 0)) { // auto-protocol
             throw new Error; // reliable errno
         }
@@ -50,7 +50,7 @@ 
     /**
      * @return int
      */
-    public static function getType () {
+    public static function getType() {
         return 0;
     }
 
@@ -66,14 +66,14 @@ 
      * @return int
      * @throws Error
      */
-    public static function select (array &$read, array &$write, array &$except, $timeout = null) {
+    public static function select(array &$read, array &$write, array &$except, $timeout = null) {
         $getResource = function(SocketInterface $socket) {
             return $socket->getResource();
         };
         // PHP 7.1 broke by-reference array_walk_recursive, use array_map instead.
-        $r = array_map($getResource,$read);
-        $w = array_map($getResource,$write);
-        $e = array_map($getResource,$except);
+        $r = array_map($getResource, $read);
+        $w = array_map($getResource, $write);
+        $e = array_map($getResource, $except);
         $usec = (int)(fmod($timeout, 1) * 1000000); // ignored if timeout is null
         $count = @socket_select($r, $w, $e, $timeout, $usec);
         if ($count === false) {
@@ -96,12 +96,12 @@ 
      * @throws Error (`SOCKET_EBADFD`) There was a pending error on the socket, including `SO_ERROR`.
      * The existing error code is set in the extra data.
      */
-    public function __construct ($resource) {
+    public function __construct($resource) {
         if (!is_resource($resource) or get_resource_type($resource) !== 'Socket') {
             throw new InvalidArgumentException('Expected an open socket resource.', SOCKET_EBADF);
         }
         elseif (socket_get_option($resource, SOL_SOCKET, SO_TYPE) !== static::getType()) {
-            throw new InvalidArgumentException('The given socket resource is of the wrong type for ' . get_class(), SOCKET_ESOCKTNOSUPPORT);
+            throw new InvalidArgumentException('The given socket resource is of the wrong type for '.get_class(), SOCKET_ESOCKTNOSUPPORT);
         }
         elseif ($errno = Error::getLast($resource)) {
             $error = new Error(SOCKET_EBADFD);
@@ -116,7 +116,7 @@ 
     /**
      * Closes the socket if it's open.
      */
-    public function __destruct () {
+    public function __destruct() {
         $this->close();
     }
 
@@ -131,7 +131,7 @@ 
      * @return $this
      * @throws Error
      */
-    public function await ($channel) {
+    public function await($channel) {
         $select = [$channel => [$this->resource]];
         $count = @socket_select($select[self::CH_READ], $select[self::CH_WRITE], $select[self::CH_EXCEPT], null);
         if (!$count) {
@@ -151,7 +151,7 @@ 
      *
      * @return $this
      */
-    public function close () {
+    public function close() {
         // socket_close() never errors, but we guard anyway to prevent
         // a redundant call to onClose(), and an incorrect call to it if
         // the constructor failed and the destructor is calling this.
@@ -165,7 +165,7 @@ 
     /**
      * @return int
      */
-    final public function getDomain () {
+    final public function getDomain() {
         return $this->domain;
     }
 
@@ -176,7 +176,7 @@ 
      *
      * @return int
      */
-    final public function getId () {
+    final public function getId() {
         return (int)$this->resource;
     }
 
@@ -189,7 +189,7 @@ 
      * @throws Error The socket has no such option or is closed.
      * @return mixed The option's value. This is never `false`.
      */
-    public function getOption ($option) {
+    public function getOption($option) {
         $value = @socket_get_option($this->resource, SOL_SOCKET, $option);
         if ($value === false) {
             throw new Error($this->resource, SOCKET_EINVAL);
@@ -200,14 +200,14 @@ 
     /**
      * @return int
      */
-    final public function getProtocol () {
+    final public function getProtocol() {
         return $this->protocol;
     }
 
     /**
      * @return resource
      */
-    final public function getResource () {
+    final public function getResource() {
         return $this->resource;
     }
 
@@ -219,7 +219,7 @@ 
      * @throws Error
      * @return array String address and integer port at indices `0` and `1`.
      */
-    public function getSockName () {
+    public function getSockName() {
         if (!@socket_getsockname($this->resource, $addr, $port)) {
             throw new Error($this->resource, SOCKET_EOPNOTSUPP);
         }
@@ -234,7 +234,7 @@ 
      * @return bool
      * @throws Error
      */
-    public function isExceptional () {
+    public function isExceptional() {
         return $this->isReady(self::CH_EXCEPT);
     }
 
@@ -243,7 +243,7 @@ 
      *
      * @return bool
      */
-    public function isOpen () {
+    public function isOpen() {
         return is_resource($this->resource);
     }
 
@@ -255,7 +255,7 @@ 
      * @return bool
      * @throws Error
      */
-    public function isReadable () {
+    public function isReadable() {
         return $this->isReady(self::CH_READ);
     }
 
@@ -269,7 +269,7 @@ 
      * @throws Error
      * @return bool
      */
-    public function isReady ($channel, $timeout = 0.0) {
+    public function isReady($channel, $timeout = 0.0) {
         $usec = (int)(fmod($timeout, 1) * 1000000); // ignored if timeout is null
         $select = [$channel => [$this->resource]];
         $count = $count = @socket_select($select[self::CH_READ], $select[self::CH_WRITE], $select[self::CH_EXCEPT], $timeout, $usec);
@@ -287,7 +287,7 @@ 
      * @return bool
      * @throws Error
      */
-    public function isWritable () {
+    public function isWritable() {
         return $this->isReady(self::CH_WRITE, 0);
     }
 
@@ -296,7 +296,7 @@ 
      *
      * @return void
      */
-    protected function onClose () { }
+    protected function onClose() { }
 
     /**
      * Stub. Called before an I/O channel is shut down.
@@ -304,14 +304,14 @@ 
      * @param int $channel
      * @return void
      */
-    protected function onShutdown ($channel) { }
+    protected function onShutdown($channel) { }
 
     /**
      * Stub. Called when an I/O timeout has occurred, before it is thrown.
      *
      * @return void
      */
-    protected function onTimeout () { }
+    protected function onTimeout() { }
 
     /**
      * Enables or disables blocking.
@@ -331,7 +331,7 @@ 
      * @throws Error
      * @return $this
      */
-    public function setBlocking ($blocking) {
+    public function setBlocking($blocking) {
         if ($blocking) {
             $success = @socket_set_block($this->resource);
         }
@@ -354,7 +354,7 @@ 
      * @throws Error
      * @return $this
      */
-    public function setOption ($option, $value) {
+    public function setOption($option, $value) {
         if (!@socket_set_option($this->resource, SOL_SOCKET, $option, $value)) {
             throw new Error($this->resource, SOCKET_EINVAL);
         }
@@ -368,7 +368,7 @@ 
      * @throws Error
      * @return $this
      */
-    public function setTimeout ($timeout) {
+    public function setTimeout($timeout) {
         $timeval = ['sec' => (int)$timeout, 'usec' => (int)(fmod($timeout, 1) * 1000000)];
         $this->setOption(SO_RCVTIMEO, $timeval);
         $this->setOption(SO_SNDTIMEO, $timeval);
@@ -395,7 +395,7 @@ 
      * @throws Error
      * @return $this
      */
-    public function shutdown ($channel) {
+    public function shutdown($channel) {
         $this->onShutdown($channel);
         if (!@socket_shutdown($this->resource, $channel)) {
             throw new Error($this->resource); // reliable errno