comet

type Conn struct {
	// contains filtered or unexported fields
}

type ConnectHandler struct {
	sync.Map
}

type IConn interface {

	// Context returns a user-defined context.
	Context() (ctx interface{})

	// SetContext sets a user-defined context.
	SetContext(ctx interface{})

	// LocalAddr is the connection's local socket address.
	LocalAddr() (addr net.Addr)

	// RemoteAddr is the connection's remote peer address.
	RemoteAddr() (addr net.Addr)

	// Read reads all data from inbound ring-buffer and event-loop-buffer without moving "read" pointer, which means
	// it does not evict the data from buffers actually and those data will present in buffers until the
	// ResetBuffer method is called.
	Read() (buf []byte)

	// AsyncWrite writes data to client/connection asynchronously, usually you would call it in individual goroutines
	// instead of the event-loop goroutines.
	AsyncWrite(buf []byte) error

	// Close closes the current connection.
	Close() error
}

type IEvent interface {
	// Parameter:out is the return value which is going to be sent back to the client.
	OnMessage(frame []byte, c IConn)
	// OnClosed fires when a connection has been closed.
	// The parameter:err is the last known connection error.
	OnClosed(c IConn, err error)
}

type IServer interface {
	// 启动zim服务
	Serve(event IEvent, port int)
	// 停止zim服务
	Stop()
}

type TCPHandler struct {
	*gnet.EventServer
	// contains filtered or unexported fields
}

type WSSHandler struct {
	*gnet.EventServer
	// contains filtered or unexported fields
}