File tree Expand file tree Collapse file tree 2 files changed +9
-23
lines changed Expand file tree Collapse file tree 2 files changed +9
-23
lines changed Original file line number Diff line number Diff line change 9
9
use Clue \Redis \Protocol \Model \ErrorReplyException ;
10
10
use Clue \Redis \Protocol \Serializer \SerializerInterface ;
11
11
use Clue \Redis \Protocol \Factory as ProtocolFactory ;
12
- use Clue \React \Redis \Request ;
13
12
use UnderflowException ;
14
13
use RuntimeException ;
14
+ use React \Promise \Deferred ;
15
+ use Clue \Redis \Protocol \Model \ErrorReply ;
15
16
16
17
class Client extends EventEmitter
17
18
{
@@ -79,7 +80,7 @@ public function __call($name, $args)
79
80
80
81
$ this ->stream ->write ($ this ->serializer ->getRequestMessage ($ name , $ args ));
81
82
82
- $ request = new Request ( $ name );
83
+ $ request = new Deferred ( );
83
84
$ this ->requests []= $ request ;
84
85
85
86
return $ request ->promise ();
@@ -94,9 +95,13 @@ public function handleReply($data)
94
95
}
95
96
96
97
$ request = array_shift ($ this ->requests );
97
- /* @var $request Request */
98
+ /* @var $request Deferred */
98
99
99
- $ request ->handleReply ($ data );
100
+ if ($ data instanceof ErrorReply) {
101
+ $ request ->reject ($ data );
102
+ } else {
103
+ $ request ->resolve ($ data ->getValueNative ());
104
+ }
100
105
101
106
if ($ this ->ending && !$ this ->isBusy ()) {
102
107
$ this ->close ();
Load Diff This file was deleted.
You can’t perform that action at this time.
0 commit comments