@@ -74,7 +74,7 @@ public function addReadStream($stream, $listener)
7474 }
7575
7676 $ event = \event_new ();
77- \event_set ($ event , $ stream , EV_PERSIST | EV_READ , $ this ->streamCallback );
77+ \event_set ($ event , $ stream , \ EV_PERSIST | \ EV_READ , $ this ->streamCallback );
7878 \event_base_set ($ event , $ this ->eventBase );
7979 \event_add ($ event );
8080
@@ -90,7 +90,7 @@ public function addWriteStream($stream, $listener)
9090 }
9191
9292 $ event = \event_new ();
93- \event_set ($ event , $ stream , EV_PERSIST | EV_WRITE , $ this ->streamCallback );
93+ \event_set ($ event , $ stream , \ EV_PERSIST | \ EV_WRITE , $ this ->streamCallback );
9494 \event_base_set ($ event , $ this ->eventBase );
9595 \event_add ($ event );
9696
@@ -170,7 +170,7 @@ public function addSignal($signal, $listener)
170170
171171 if (!isset ($ this ->signalEvents [$ signal ])) {
172172 $ this ->signalEvents [$ signal ] = \event_new ();
173- \event_set ($ this ->signalEvents [$ signal ], $ signal , EV_PERSIST | EV_SIGNAL , array ($ this ->signals , 'call ' ));
173+ \event_set ($ this ->signalEvents [$ signal ], $ signal , \ EV_PERSIST | \ EV_SIGNAL , array ($ this ->signals , 'call ' ));
174174 \event_base_set ($ this ->signalEvents [$ signal ], $ this ->eventBase );
175175 \event_add ($ this ->signalEvents [$ signal ]);
176176 }
@@ -194,9 +194,9 @@ public function run()
194194 while ($ this ->running ) {
195195 $ this ->futureTickQueue ->tick ();
196196
197- $ flags = EVLOOP_ONCE ;
197+ $ flags = \ EVLOOP_ONCE ;
198198 if (!$ this ->running || !$ this ->futureTickQueue ->isEmpty ()) {
199- $ flags |= EVLOOP_NONBLOCK ;
199+ $ flags |= \ EVLOOP_NONBLOCK ;
200200 } elseif (!$ this ->readEvents && !$ this ->writeEvents && !$ this ->timerEvents ->count () && $ this ->signals ->isEmpty ()) {
201201 break ;
202202 }
@@ -271,11 +271,11 @@ private function createStreamCallback()
271271 $ this ->streamCallback = function ($ stream , $ flags ) use (&$ read , &$ write ) {
272272 $ key = (int ) $ stream ;
273273
274- if (EV_READ === (EV_READ & $ flags ) && isset ($ read [$ key ])) {
274+ if (\ EV_READ === (\ EV_READ & $ flags ) && isset ($ read [$ key ])) {
275275 \call_user_func ($ read [$ key ], $ stream );
276276 }
277277
278- if (EV_WRITE === (EV_WRITE & $ flags ) && isset ($ write [$ key ])) {
278+ if (\ EV_WRITE === (\ EV_WRITE & $ flags ) && isset ($ write [$ key ])) {
279279 \call_user_func ($ write [$ key ], $ stream );
280280 }
281281 };
0 commit comments