33namespace React \Tests \EventLoop ;
44
55use React \EventLoop \StreamSelectLoop ;
6+ use React \EventLoop \ExtUvLoop ;
67
78abstract class AbstractLoopTest extends TestCase
89{
@@ -144,6 +145,10 @@ public function testAddWriteStreamTriggersWhenSocketConnectionRefused()
144145
145146 public function testAddReadStream ()
146147 {
148+ if ($ this ->loop instanceof ExtUvLoop && DIRECTORY_SEPARATOR === '\\' ) {
149+ $ this ->markTestIncomplete ('Ticking ExtUvLoop not supported on Windows ' );
150+ }
151+
147152 list ($ input , $ output ) = $ this ->createSocketPair ();
148153
149154 $ this ->loop ->addReadStream ($ input , $ this ->expectCallableExactly (2 ));
@@ -157,6 +162,10 @@ public function testAddReadStream()
157162
158163 public function testAddReadStreamIgnoresSecondCallable ()
159164 {
165+ if ($ this ->loop instanceof ExtUvLoop && DIRECTORY_SEPARATOR === '\\' ) {
166+ $ this ->markTestIncomplete ('Ticking ExtUvLoop not supported on Windows ' );
167+ }
168+
160169 list ($ input , $ output ) = $ this ->createSocketPair ();
161170
162171 $ this ->loop ->addReadStream ($ input , $ this ->expectCallableExactly (2 ));
@@ -206,6 +215,10 @@ private function subAddReadStreamReceivesDataFromStreamReference()
206215
207216 public function testAddWriteStream ()
208217 {
218+ if ($ this ->loop instanceof ExtUvLoop && DIRECTORY_SEPARATOR === '\\' ) {
219+ $ this ->markTestIncomplete ('Ticking ExtUvLoop not supported on Windows ' );
220+ }
221+
209222 list ($ input ) = $ this ->createSocketPair ();
210223
211224 $ this ->loop ->addWriteStream ($ input , $ this ->expectCallableExactly (2 ));
@@ -215,6 +228,10 @@ public function testAddWriteStream()
215228
216229 public function testAddWriteStreamIgnoresSecondCallable ()
217230 {
231+ if ($ this ->loop instanceof ExtUvLoop && DIRECTORY_SEPARATOR === '\\' ) {
232+ $ this ->markTestIncomplete ('Ticking ExtUvLoop not supported on Windows ' );
233+ }
234+
218235 list ($ input ) = $ this ->createSocketPair ();
219236
220237 $ this ->loop ->addWriteStream ($ input , $ this ->expectCallableExactly (2 ));
@@ -225,6 +242,10 @@ public function testAddWriteStreamIgnoresSecondCallable()
225242
226243 public function testRemoveReadStreamInstantly ()
227244 {
245+ if ($ this ->loop instanceof ExtUvLoop && DIRECTORY_SEPARATOR === '\\' ) {
246+ $ this ->markTestIncomplete ('Ticking ExtUvLoop not supported on Windows ' );
247+ }
248+
228249 list ($ input , $ output ) = $ this ->createSocketPair ();
229250
230251 $ this ->loop ->addReadStream ($ input , $ this ->expectCallableNever ());
@@ -236,6 +257,10 @@ public function testRemoveReadStreamInstantly()
236257
237258 public function testRemoveReadStreamAfterReading ()
238259 {
260+ if ($ this ->loop instanceof ExtUvLoop && DIRECTORY_SEPARATOR === '\\' ) {
261+ $ this ->markTestIncomplete ('Ticking ExtUvLoop not supported on Windows ' );
262+ }
263+
239264 list ($ input , $ output ) = $ this ->createSocketPair ();
240265
241266 $ this ->loop ->addReadStream ($ input , $ this ->expectCallableOnce ());
@@ -251,6 +276,10 @@ public function testRemoveReadStreamAfterReading()
251276
252277 public function testRemoveWriteStreamInstantly ()
253278 {
279+ if ($ this ->loop instanceof ExtUvLoop && DIRECTORY_SEPARATOR === '\\' ) {
280+ $ this ->markTestIncomplete ('Ticking ExtUvLoop not supported on Windows ' );
281+ }
282+
254283 list ($ input ) = $ this ->createSocketPair ();
255284
256285 $ this ->loop ->addWriteStream ($ input , $ this ->expectCallableNever ());
@@ -260,6 +289,10 @@ public function testRemoveWriteStreamInstantly()
260289
261290 public function testRemoveWriteStreamAfterWriting ()
262291 {
292+ if ($ this ->loop instanceof ExtUvLoop && DIRECTORY_SEPARATOR === '\\' ) {
293+ $ this ->markTestIncomplete ('Ticking ExtUvLoop not supported on Windows ' );
294+ }
295+
263296 list ($ input ) = $ this ->createSocketPair ();
264297
265298 $ this ->loop ->addWriteStream ($ input , $ this ->expectCallableOnce ());
@@ -271,6 +304,10 @@ public function testRemoveWriteStreamAfterWriting()
271304
272305 public function testRemoveStreamForReadOnly ()
273306 {
307+ if ($ this ->loop instanceof ExtUvLoop && DIRECTORY_SEPARATOR === '\\' ) {
308+ $ this ->markTestIncomplete ('Ticking ExtUvLoop not supported on Windows ' );
309+ }
310+
274311 list ($ input , $ output ) = $ this ->createSocketPair ();
275312
276313 $ this ->loop ->addReadStream ($ input , $ this ->expectCallableNever ());
@@ -283,6 +320,10 @@ public function testRemoveStreamForReadOnly()
283320
284321 public function testRemoveStreamForWriteOnly ()
285322 {
323+ if ($ this ->loop instanceof ExtUvLoop && DIRECTORY_SEPARATOR === '\\' ) {
324+ $ this ->markTestIncomplete ('Ticking ExtUvLoop not supported on Windows ' );
325+ }
326+
286327 list ($ input , $ output ) = $ this ->createSocketPair ();
287328
288329 fwrite ($ output , "foo \n" );
@@ -505,6 +546,10 @@ public function testFutureTick()
505546
506547 public function testFutureTickFiresBeforeIO ()
507548 {
549+ if ($ this ->loop instanceof ExtUvLoop && DIRECTORY_SEPARATOR === '\\' ) {
550+ $ this ->markTestIncomplete ('Ticking ExtUvLoop not supported on Windows ' );
551+ }
552+
508553 list ($ stream ) = $ this ->createSocketPair ();
509554
510555 $ this ->loop ->addWriteStream (
@@ -525,6 +570,9 @@ function () {
525570 $ this ->tickLoop ($ this ->loop );
526571 }
527572
573+ /**
574+ * @depends testFutureTickFiresBeforeIO
575+ */
528576 public function testRecursiveFutureTick ()
529577 {
530578 list ($ stream ) = $ this ->createSocketPair ();
0 commit comments