File tree Expand file tree Collapse file tree 2 files changed +23
-7
lines changed Expand file tree Collapse file tree 2 files changed +23
-7
lines changed Original file line number Diff line number Diff line change
1
+ <?php
2
+
3
+ namespace Clue \React \Redis ;
4
+
5
+ use Evenement \EventEmitterInterface ;
6
+
7
+ interface Client extends EventEmitterInterface
8
+ {
9
+ public function __call ($ name , $ args );
10
+
11
+ public function isBusy ();
12
+
13
+ /**
14
+ * end connection once all pending requests have been replied to
15
+ *
16
+ * @uses self::close() once all replies have been received
17
+ * @see self::close() for closing the connection immediately
18
+ */
19
+ public function end ();
20
+
21
+ public function close ();
22
+ }
Original file line number Diff line number Diff line change 15
15
use Clue \Redis \Protocol \Model \ErrorReply ;
16
16
use Clue \Redis \Protocol \Model \ModelInterface ;
17
17
18
- class StreamingClient extends EventEmitter
18
+ class StreamingClient extends EventEmitter implements Client
19
19
{
20
20
private $ stream ;
21
21
private $ parser ;
@@ -108,12 +108,6 @@ public function isBusy()
108
108
return !!$ this ->requests ;
109
109
}
110
110
111
- /**
112
- * end connection once all pending requests have been replied to
113
- *
114
- * @uses self::close() once all replies have been received
115
- * @see self::close() for closing the connection immediately
116
- */
117
111
public function end ()
118
112
{
119
113
$ this ->ending = true ;
You can’t perform that action at this time.
0 commit comments