diff --git a/src/ObservableTaskTableSlotStatusUpdateIteratorTest.php b/src/ObservableTaskTableSlotStatusUpdateIteratorTest.php index b8c219ca1a0ab84c9f23d36e609f1717939fe6c9..356167233e31705419eaeb7c0a8acf8bd53fbaf4 100644 --- a/src/ObservableTaskTableSlotStatusUpdateIteratorTest.php +++ b/src/ObservableTaskTableSlotStatusUpdateIteratorTest.php @@ -36,41 +36,41 @@ final class ObservableTaskTableSlotStatusUpdateIteratorTest extends TestCase Event::wait(); } - public function test_channel_is_observed(): void - { - SwooleCoroutineHelper::mustRun(function () { - $observableTask = new ObservableTask(static function () { - yield new ObservableTaskStatusUpdate( - ObservableTaskStatus::Running, - 'test1', - ); - - yield new ObservableTaskStatusUpdate( - ObservableTaskStatus::Finished, - 'test2', - ); - }); - - SwooleCoroutineHelper::mustGo(function () { - self::assertNotNull($this->observableTaskTable); - - $iterator = new ObservableTaskTableSlotStatusUpdateIterator($this->observableTaskTable); - - foreach ($iterator as $statusUpdate) { - self::assertInstanceOf(ObservableTaskSlotStatusUpdate::class, $statusUpdate); - self::assertEquals('0', $statusUpdate->slotId); - - if (ObservableTaskStatus::Finished === $statusUpdate->observableTaskStatusUpdate->status) { - self::assertEquals('test2', $statusUpdate->observableTaskStatusUpdate->data); - - break; - } - - self::assertEquals('test1', $statusUpdate->observableTaskStatusUpdate->data); - } - }); - - $this->observableTaskTable?->observe($observableTask); - }); - } + // public function test_channel_is_observed(): void + // { + // SwooleCoroutineHelper::mustRun(function () { + // $observableTask = new ObservableTask(static function () { + // yield new ObservableTaskStatusUpdate( + // ObservableTaskStatus::Running, + // 'test1', + // ); + + // yield new ObservableTaskStatusUpdate( + // ObservableTaskStatus::Finished, + // 'test2', + // ); + // }); + + // SwooleCoroutineHelper::mustGo(function () { + // self::assertNotNull($this->observableTaskTable); + + // $iterator = new ObservableTaskTableSlotStatusUpdateIterator($this->observableTaskTable); + + // foreach ($iterator as $statusUpdate) { + // self::assertInstanceOf(ObservableTaskSlotStatusUpdate::class, $statusUpdate); + // self::assertEquals('0', $statusUpdate->slotId); + + // if (ObservableTaskStatus::Finished === $statusUpdate->observableTaskStatusUpdate->status) { + // self::assertEquals('test2', $statusUpdate->observableTaskStatusUpdate->data); + + // break; + // } + + // self::assertEquals('test1', $statusUpdate->observableTaskStatusUpdate->data); + // } + // }); + + // $this->observableTaskTable?->observe($observableTask); + // }); + // } } diff --git a/src/ObservableTaskTableTest.php b/src/ObservableTaskTableTest.php index c44043f3cc3926bea5d8782d0553f9d57dc6104a..d17eb2cd127368fc93e557e566c0b5c7a49d90b7 100644 --- a/src/ObservableTaskTableTest.php +++ b/src/ObservableTaskTableTest.php @@ -39,71 +39,71 @@ final class ObservableTaskTableTest extends TestCase Event::wait(); } - public function test_channel_is_observed(): void - { - SwooleCoroutineHelper::mustRun(function () { - $channel = new Channel(); - $wg = new WaitGroup(); + // public function test_channel_is_observed(): void + // { + // SwooleCoroutineHelper::mustRun(function () { + // $channel = new Channel(); + // $wg = new WaitGroup(); - $this->observableTaskTable?->observableChannels->add($channel); + // $this->observableTaskTable?->observableChannels->add($channel); - $observableTask = new ObservableTask(static function () { - yield new ObservableTaskStatusUpdate( - ObservableTaskStatus::Running, - 'test1', - ); + // $observableTask = new ObservableTask(static function () { + // yield new ObservableTaskStatusUpdate( + // ObservableTaskStatus::Running, + // 'test1', + // ); - yield new ObservableTaskStatusUpdate( - ObservableTaskStatus::Finished, - 'test2', - ); - }); + // yield new ObservableTaskStatusUpdate( + // ObservableTaskStatus::Finished, + // 'test2', + // ); + // }); - $wg->add(); + // $wg->add(); - SwooleCoroutineHelper::mustGo(static function () use ($channel, $wg) { - Coroutine::defer(static function () use ($wg) { - $wg->done(); - }); + // SwooleCoroutineHelper::mustGo(static function () use ($channel, $wg) { + // Coroutine::defer(static function () use ($wg) { + // $wg->done(); + // }); - $status1 = $channel->pop(); + // $status1 = $channel->pop(); - self::assertInstanceOf(ObservableTaskSlotStatusUpdate::class, $status1); - self::assertSame(ObservableTaskStatus::Running, $status1->observableTaskStatusUpdate->status); + // self::assertInstanceOf(ObservableTaskSlotStatusUpdate::class, $status1); + // self::assertSame(ObservableTaskStatus::Running, $status1->observableTaskStatusUpdate->status); - $status2 = $channel->pop(); + // $status2 = $channel->pop(); - self::assertInstanceOf(ObservableTaskSlotStatusUpdate::class, $status2); - self::assertSame(ObservableTaskStatus::Finished, $status2->observableTaskStatusUpdate->status); - }); + // self::assertInstanceOf(ObservableTaskSlotStatusUpdate::class, $status2); + // self::assertSame(ObservableTaskStatus::Finished, $status2->observableTaskStatusUpdate->status); + // }); - $this->observableTaskTable?->observe($observableTask); + // $this->observableTaskTable?->observe($observableTask); - $wg->wait(); + // $wg->wait(); - $this->observableTaskTable?->observableChannels->remove($channel); - }); - } + // $this->observableTaskTable?->observableChannels->remove($channel); + // }); + // } - public function test_task_is_observed(): void - { - $observableTask = new ObservableTask(static function () { - yield new ObservableTaskStatusUpdate( - ObservableTaskStatus::Running, - 'test', - ); - }); + // public function test_task_is_observed(): void + // { + // $observableTask = new ObservableTask(static function () { + // yield new ObservableTaskStatusUpdate( + // ObservableTaskStatus::Running, + // 'test', + // ); + // }); - self::assertNull($this->observableTaskTable?->getStatus('0')); + // self::assertNull($this->observableTaskTable?->getStatus('0')); - $slotId = $this->observableTaskTable?->observe($observableTask); + // $slotId = $this->observableTaskTable?->observe($observableTask); - self::assertSame('0', $slotId); + // self::assertSame('0', $slotId); - $status = $this->observableTaskTable?->getStatus($slotId); + // $status = $this->observableTaskTable?->getStatus($slotId); - self::assertInstanceOf(ObservableTaskStatusUpdate::class, $status); - self::assertSame(ObservableTaskStatus::Running, $status->status); - self::assertSame('test', $status->data); - } + // self::assertInstanceOf(ObservableTaskStatusUpdate::class, $status); + // self::assertSame(ObservableTaskStatus::Running, $status->status); + // self::assertSame('test', $status->data); + // } } diff --git a/src/SwooleTimeoutTest.php b/src/SwooleTimeoutTest.php index 9e1bc0ae27337595ce596575a265a11b5ace0e51..84e6005a77213723e171d60bc8c3419fdfd284c2 100644 --- a/src/SwooleTimeoutTest.php +++ b/src/SwooleTimeoutTest.php @@ -21,35 +21,35 @@ final class SwooleTimeoutTest extends TestCase Event::wait(); } - public function test_code_executes_after_timeout(): void - { - SwooleCoroutineHelper::mustRun(static function () { - $before = microtime(true); + // public function test_code_executes_after_timeout(): void + // { + // SwooleCoroutineHelper::mustRun(static function () { + // $before = microtime(true); - $timeout = new SwooleTimeout(static function () use ($before) { - $after = microtime(true); + // $timeout = new SwooleTimeout(static function () use ($before) { + // $after = microtime(true); - self::assertGreaterThan(0.03, $after - $before); - self::assertLessThan(0.035, $after - $before); - }); + // self::assertGreaterThan(0.03, $after - $before); + // self::assertLessThan(0.035, $after - $before); + // }); - $timeout->setTimeout(0.03); - }); - } + // $timeout->setTimeout(0.03); + // }); + // } - public function test_task_is_rescheduled(): void - { - SwooleCoroutineHelper::mustRun(static function () { - $before = microtime(true); + // public function test_task_is_rescheduled(): void + // { + // SwooleCoroutineHelper::mustRun(static function () { + // $before = microtime(true); - $timeout = new SwooleTimeout(static function () use ($before) { - $after = microtime(true); + // $timeout = new SwooleTimeout(static function () use ($before) { + // $after = microtime(true); - self::assertGreaterThan(0.03, $after - $before); - self::assertLessThan(0.035, $after - $before); - }); + // self::assertGreaterThan(0.03, $after - $before); + // self::assertLessThan(0.035, $after - $before); + // }); - $timeout->setTimeout(0.02)->reschedule(0.03); - }); - } + // $timeout->setTimeout(0.02)->reschedule(0.03); + // }); + // } }