@@ -104,7 +104,7 @@ discard block |
||
| 104 | 104 | * @param array $server The configuration options for the connection |
| 105 | 105 | * @param array $options The global options shared by all Sentinel clients |
| 106 | 106 | * |
| 107 | - * @return Client The Predis Client instance |
|
| 107 | + * @return PredisConnection The Predis Client instance |
|
| 108 | 108 | */ |
| 109 | 109 | protected function createSingleClient(array $server, array $options) |
| 110 | 110 | { |
@@ -133,7 +133,7 @@ discard block |
||
| 133 | 133 | * Sets the Sentinel-specific connection options on a Predis Client |
| 134 | 134 | * connection |
| 135 | 135 | * |
| 136 | - * @param Client $client The Predis Client to set options for |
|
| 136 | + * @param PredisConnection $client The Predis Client to set options for |
|
| 137 | 137 | * @param array $sentinelOpts The options supported by Predis for |
| 138 | 138 | * Sentinel-specific connections |
| 139 | 139 | * |
@@ -146,7 +146,7 @@ |
||
| 146 | 146 | foreach ($sentinelOpts as $option => $value) { |
| 147 | 147 | DynamicMethod::parseFromUnderscore($option) |
| 148 | 148 | ->prepend('set') |
| 149 | - ->callOn($client, [ $value ]); |
|
| 149 | + ->callOn($client, [$value]); |
|
| 150 | 150 | } |
| 151 | 151 | } |
| 152 | 152 | } |
@@ -126,7 +126,7 @@ discard block |
||
| 126 | 126 | $method = 'subscribe' |
| 127 | 127 | ) { |
| 128 | 128 | $this->retryOnFailure(function () use ($method, $channels, $callback) { |
| 129 | - $loop = $this->pubSubLoop([ $method => (array) $channels ]); |
|
| 129 | + $loop = $this->pubSubLoop([$method => (array) $channels]); |
|
| 130 | 130 | |
| 131 | 131 | if ($method === 'psubscribe') { |
| 132 | 132 | $messageKind = 'pmessage'; |
@@ -201,7 +201,7 @@ discard block |
||
| 201 | 201 | */ |
| 202 | 202 | public function getClientFor($connectionID) |
| 203 | 203 | { |
| 204 | - if (! $connection = $this->getConnectionById($connectionID)) { |
|
| 204 | + if (!$connection = $this->getConnectionById($connectionID)) { |
|
| 205 | 205 | throw new InvalidArgumentException( |
| 206 | 206 | "Invalid connection ID: $connectionID." |
| 207 | 207 | ); |