Versions in this module Expand all Collapse all v0 v0.1.0 Aug 14, 2020 Changes in this version + const PPRO_HTTP + const PPRO_TCP_LTV + const PPRO_UDP_LTV + const PPRO_WS_LTV + func BindProcessorHandler(peer void.Peer, name string, userCallback void.EventHandler, ...) + func NewEventQueue() void.EventQueue + func NewProcessor() void.Processor + func NewQueuedEventCallback(callback void.EventHandler) void.EventHandler + func QueuedCall(queue void.EventQueue, callback func()) + func Register(name string, f ProcessorBinder) + func SessionQueuedCall(s void.Session, callback func()) + type ProcessorBinder func(bundle void.Processor, userCallback void.EventHandler, args ...interface{}) + type RecvEvent struct + 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 + func NewSendEvent(s void.Session, m interface{}) *SendEvent + func (s *SendEvent) Message() interface{} + func (s *SendEvent) Session() void.Session