stream

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

type Option func(s *SessionCtx)

type PacketProcessor interface {
	Listen(onPacket func(p []byte))
	Data(data []byte) (n int)
}

type Session interface {
	OnData(p []byte, size int, err error)
	Read(p []byte) (size int, err error)
	Write(p []byte) (size int, err error)
}

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

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