processor

package

v0.1.0 Latest Latest Go to latest Published: Aug 14, 2020 License: MIT Imports: 4 Imported by: 0

Details

View Source

const (
	PPRO_TCP_LTV = "tcp.ltv"
	PPRO_UDP_LTV = "udp.ltv"
	PPRO_WS_LTV  = "ws.ltv"
	PPRO_HTTP    = "http"
)

This section is empty.

func BindProcessorHandler(peer void.Peer, name string, userCallback void.EventHandler, args ...interface{})

func NewEventQueue() void.EventQueue

func NewProcessor() void.Processor

func NewQueuedEventCallback(callback void.EventHandler) void.EventHandler

让EventCallback保证放在 session 的队列里，而不是并发的

func QueuedCall(queue void.EventQueue, callback func())

有队列时队列调用，无队列时直接调用

func Register(name string, f ProcessorBinder)

func SessionQueuedCall(s void.Session, callback func())

在会话对应的Peer上的事件队列中执行callback，如果没有队列，则马上执行

type ProcessorBinder func(bundle void.Processor, userCallback void.EventHandler, args ...interface{})

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

接受到消息

func NewRecvEvent(s void.Session, m interface{}) *RecvEvent

func (r *RecvEvent) Message() interface{}

func (r *RecvEvent) Send(msg interface{})

func (r *RecvEvent) Session() void.Session

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

会话开始发送数据事件

func NewSendEvent(s void.Session, m interface{}) *SendEvent

func (s *SendEvent) Message() interface{}

func (s *SendEvent) Session() void.Session

Path	Synopsis
tcp