|
@@ -126,7 +126,9 @@ class StreamConnection extends AbstractConnection
|
|
|
parent::connect();
|
|
|
|
|
|
if ($this->initCmds) {
|
|
|
- $this->sendInitializationCommands();
|
|
|
+ foreach ($this->initCmds as $command) {
|
|
|
+ $this->executeCommand($command);
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
|
|
@@ -141,19 +143,6 @@ class StreamConnection extends AbstractConnection
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- /**
|
|
|
- * Sends the initialization commands to Redis when the connection is opened.
|
|
|
- */
|
|
|
- private function sendInitializationCommands()
|
|
|
- {
|
|
|
- foreach ($this->initCmds as $command) {
|
|
|
- $this->writeCommand($command);
|
|
|
- }
|
|
|
- foreach ($this->initCmds as $command) {
|
|
|
- $this->readResponse($command);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
/**
|
|
|
* Performs a write operation on the stream of the buffer containing a
|
|
|
* command serialized with the Redis wire protocol.
|