diff options
author | Valery Piashchynski <[email protected]> | 2021-07-14 14:55:24 +0300 |
---|---|---|
committer | Valery Piashchynski <[email protected]> | 2021-07-14 14:55:24 +0300 |
commit | cd07985494b3ebb03fd6553bed9aa1393052ffc5 (patch) | |
tree | ea2c89de3fb7765af84ff9dac7c83881bc8869d2 /tests | |
parent | d099e47ab28dd044d34e18347a4c714b8af3d612 (diff) |
Implement Pause/Resume/Stop
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'tests')
-rw-r--r-- | tests/plugins/jobs/jobs_plugin_test.go | 2 | ||||
-rw-r--r-- | tests/psr-worker.php | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/tests/plugins/jobs/jobs_plugin_test.go b/tests/plugins/jobs/jobs_plugin_test.go index c06b74e4..f8a5c3e7 100644 --- a/tests/plugins/jobs/jobs_plugin_test.go +++ b/tests/plugins/jobs/jobs_plugin_test.go @@ -97,7 +97,7 @@ func TestTEMP_INTI(t *testing.T) { } }() - time.Sleep(time.Second * 30000) + time.Sleep(time.Second * 3) stopCh <- struct{}{} wg.Wait() } diff --git a/tests/psr-worker.php b/tests/psr-worker.php index de4befbc..db53eee2 100644 --- a/tests/psr-worker.php +++ b/tests/psr-worker.php @@ -20,7 +20,7 @@ while ($req = $psr7->waitRequest()) { try { $resp = new \Nyholm\Psr7\Response(); $resp->getBody()->write(str_repeat("hello world", 1000)); - + $psr7->respond($resp); } catch (\Throwable $e) { $psr7->getWorker()->error((string)$e); |