AsyncWrite是在什么时候发送的呢？ about gnet HOT 9 CLOSED

package server

import (
	"fmt"
	"github.com/panjf2000/gnet"
	"github.com/panjf2000/gnet/pool"
	"log"
)

type IcoServer struct {
	*gnet.EventServer
	pool *pool.WorkerPool
}

func (is *IcoServer) OnInitComplete(srv gnet.Server) (action gnet.Action) {
	log.Printf("Server is running under multi-core: %t, loops: %d\n", srv.Multicore, srv.NumLoops)
	return
}

func (is *IcoServer) OnOpened(c gnet.Conn) (out []byte, action gnet.Action) {
	fmt.Println("new client connected!")
	c.ResetBuffer()
	return
}

func (is *IcoServer) React(c gnet.Conn) (out []byte, action gnet.Action) {
	data := append([]byte{}, c.Read()...)
	c.ResetBuffer()
	fmt.Println("read data...", data)

	// Use ants pool to unblock the event-loop.
	_ = is.pool.Submit(func() {
		fmt.Println("Async Writing...")
		c.AsyncWrite([]byte("hello world"))
	})

	//out = data
	//
	//action = gnet.Close

	return
}

func (is *IcoServer) PreWrite() {
	fmt.Println("writing data....")
}

func NewIcoServer(p *pool.WorkerPool) *IcoServer {
	return &IcoServer{pool: p}
}

package main

import (
	"github.com/panjf2000/gnet"
	"github.com/panjf2000/gnet/pool"
	"gnet-learning/server"
	"log"
)

func main() {
	p := pool.NewWorkerPool()
	defer p.Release()

	echo := server.NewIcoServer(p)
	log.Fatal(gnet.Serve(echo, "tcp://:9000", gnet.WithMulticore(true)))
}

package main

import (
	"fmt"
	"io/ioutil"
	"net"
	"os"
)

func main() {
	if len(os.Args) < 2 {
		fmt.Fprintf(os.Stderr, "Usage: %s host:port", os.Args[0])
	}
	//获取命令行参数 socket地址
	//server := os.Args[1]
	addr, err := net.ResolveTCPAddr("tcp4", "127.0.0.1:9000")
	checkError(err)

	//建立tcp连接
	conn, err := net.DialTCP("tcp4", nil, addr)
	checkError(err)

	//向服务端发送数据
	_, err = conn.Write([]byte("HEAD / HTTP/1.0\r\n\r\n"))
	checkError(err)
	//接收响应
	response, _ := ioutil.ReadAll(conn)
	fmt.Println(string(response))
	os.Exit(0)
}

func checkError(err error) {
	if err != nil {
		fmt.Println(err)
		os.Exit(1)
	}
}