public function onResponse(Connection $conn, $bytes)
    {
        $this->onPublishResponse($conn, $bytes);

        if ($bytes === "CLOSE_WAIT") {
            // nsqd ack客户端的StartClose, 准备关闭
            // 可以假定不会再收到任何nsqd的消息
            $conn->tryClose();
        }
    }
public function onResponse(Connection $conn, $bytes)
    {
        $this->onPublishResponse($conn, $bytes);

        if ($bytes === "CLOSE_WAIT") {
            // nsqd ack客户端的StartClose, 准备关闭
            // 可以假定不会再收到任何nsqd的消息
            $conn->tryClose();
        }
    }
public function onResponse ( Connection $ conn , $ bytes ) { $ this -> onPublishResponse ( $ conn , $ bytes ) ; if ( $ bytes === "CLOSE_WAIT" ) { // nsqd ack客户端的StartClose, 准备关闭 // 可以假定不会再收到任何nsqd的消息 $ conn -> tryClose ( ) ; } }
OnResponse is called when the connection
receives a FrameTypeResponse from nsqd
@param Connection $conn
@param string $bytes
@return void
OnResponse is called when the connection receives a FrameTypeResponse from nsqd