summaryrefslogtreecommitdiff
path: root/plugins/server/tests
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2020-12-15 14:28:30 +0300
committerValery Piashchynski <[email protected]>2020-12-15 14:28:30 +0300
commit21b51367e27f5a1b166459a115e4655d07a5d832 (patch)
treec3257a2ac38f0688e78ca2c9eeb160fb7a84c55d /plugins/server/tests
parent08f073f3bdc1288db68235c098c3a2109c6e7667 (diff)
parentd39a0735fe21d21c5aae20c4780458433a42250a (diff)
Merge branch '2.0' into plugin/reloader
# Conflicts: # go.mod # sync_worker.go
Diffstat (limited to 'plugins/server/tests')
-rw-r--r--plugins/server/tests/socket.php6
-rw-r--r--plugins/server/tests/tcp.php8
2 files changed, 7 insertions, 7 deletions
diff --git a/plugins/server/tests/socket.php b/plugins/server/tests/socket.php
index 143c3ce4..1b76481a 100644
--- a/plugins/server/tests/socket.php
+++ b/plugins/server/tests/socket.php
@@ -6,7 +6,7 @@
use Spiral\Goridge;
use Spiral\RoadRunner;
-require dirname(__DIR__) . "/../../vendor_php/autoload.php";
+require dirname(__DIR__) . "/../../tests/vendor/autoload.php";
$relay = new Goridge\SocketRelay(
"unix.sock",
@@ -16,9 +16,9 @@ $relay = new Goridge\SocketRelay(
$rr = new RoadRunner\Worker($relay);
-while ($in = $rr->receive($ctx)) {
+while ($in = $rr->waitPayload()) {
try {
- $rr->send((string)$in);
+ $rr->send((string)$in->body);
} catch (\Throwable $e) {
$rr->error((string)$e);
}
diff --git a/plugins/server/tests/tcp.php b/plugins/server/tests/tcp.php
index 2d6fb00a..c567c982 100644
--- a/plugins/server/tests/tcp.php
+++ b/plugins/server/tests/tcp.php
@@ -6,15 +6,15 @@
use Spiral\Goridge;
use Spiral\RoadRunner;
-require dirname(__DIR__) . "/../../vendor_php/autoload.php";
+require dirname(__DIR__) . "/../../tests/vendor/autoload.php";
$relay = new Goridge\SocketRelay("localhost", 9999);
$rr = new RoadRunner\Worker($relay);
-while ($in = $rr->receive($ctx)) {
+while ($in = $rr->waitPayload()) {
try {
- $rr->send((string)$in);
+ $rr->send((string)$in->body);
} catch (\Throwable $e) {
$rr->error((string)$e);
}
-} \ No newline at end of file
+}