改名

2020-10-09 12:06:05 +08:00
parent bda7085dea
commit 9815a2cb20
1 changed files with 7 additions and 0 deletions
@@ -14,6 +14,8 @@

 namespace Kafka;

+use Snowflake\Event;
+use Snowflake\Snowflake;
 use Swoole\Coroutine\Client;

 /**
@@ -342,6 +344,11 @@ class SocketSync
 		$failedWriteAttempts = 0;
 		$written = 0;
 		$buflen = strlen($buf);
+
+
+		$event = Snowflake::app()->getEvent();
+		$event->on(Event::EVENT_AFTER_REQUEST, [$this, 'close']);
+
 		while ($written < $buflen) {
 			if ($buflen - $written > self::MAX_WRITE_BUFFER) {
 				// write max buffer size