This commit is contained in:
as2252258@163.com
2021-08-28 01:25:24 +08:00
parent 30dae81e7e
commit dd79069cc5
5 changed files with 6 additions and 6 deletions
+1 -1
View File
@@ -2,7 +2,7 @@
namespace Server\Constrict; namespace Server\Constrict;
use Server\ResponseInterface; use Psr\Http\Message\ResponseInterface;
interface Emitter interface Emitter
{ {
+1 -1
View File
@@ -7,7 +7,7 @@ use Exception;
use Http\Context\Formatter\FileFormatter; use Http\Context\Formatter\FileFormatter;
use Kiri\Exception\NotFindClassException; use Kiri\Exception\NotFindClassException;
use ReflectionException; use ReflectionException;
use Server\ResponseInterface; use Psr\Http\Message\ResponseInterface;
use Swoole\Server; use Swoole\Server;
+1 -1
View File
@@ -4,7 +4,7 @@ namespace Server\Constrict;
use Http\Context\Formatter\FileFormatter; use Http\Context\Formatter\FileFormatter;
use Kiri\Exception\NotFindClassException; use Kiri\Exception\NotFindClassException;
use Server\ResponseInterface; use Psr\Http\Message\ResponseInterface;
use Swoole\Server; use Swoole\Server;
+1 -1
View File
@@ -3,7 +3,7 @@
namespace Server\Constrict; namespace Server\Constrict;
use Kiri\Exception\NotFindClassException; use Kiri\Exception\NotFindClassException;
use Server\ResponseInterface; use Psr\Http\Message\ResponseInterface;
use Swoole\Server; use Swoole\Server;
+2 -2
View File
@@ -4,7 +4,7 @@ namespace Server\Constrict;
use Kiri\Exception\NotFindClassException; use Kiri\Exception\NotFindClassException;
use Server\ResponseInterface; use Psr\Http\Message\ResponseInterface;
/** /**
* *
@@ -22,6 +22,6 @@ class WebSocketEmitter implements Emitter
*/ */
public function sender(mixed $response, ResponseInterface $emitter): void public function sender(mixed $response, ResponseInterface $emitter): void
{ {
$response->push($emitter->getClientId(), $emitter->getContent()->getData()); // $response->push($emitter->getClientId(), $emitter->getContent()->getData());
} }
} }