File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree 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 1515use Clue \Redis \Protocol \Model \ErrorReply ;
1616use Clue \Redis \Protocol \Model \ModelInterface ;
1717
18- class StreamingClient extends EventEmitter
18+ class StreamingClient extends EventEmitter implements Client
1919{
2020 private $ stream ;
2121 private $ parser ;
@@ -108,12 +108,6 @@ public function isBusy()
108108 return !!$ this ->requests ;
109109 }
110110
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- */
117111 public function end ()
118112 {
119113 $ this ->ending = true ;
You can’t perform that action at this time.
0 commit comments