summaryrefslogtreecommitdiff
path: root/tests
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-07-14 14:55:24 +0300
committerValery Piashchynski <[email protected]>2021-07-14 14:55:24 +0300
commitcd07985494b3ebb03fd6553bed9aa1393052ffc5 (patch)
treeea2c89de3fb7765af84ff9dac7c83881bc8869d2 /tests
parentd099e47ab28dd044d34e18347a4c714b8af3d612 (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.go2
-rw-r--r--tests/psr-worker.php2
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);