udpblock

Documentation

Index

• func AddLenHead(data []byte) []byte
• func GetData(data []byte) ([]byte, error)
• func NewDataReader(conn DeadlineReader) (io.ReadCloser, error)
• func NewDataWriter(conn io.Writer) (io.Writer, error)
• type DeadlineReader

Functions

func AddLenHead

func AddLenHead(data []byte) []byte

AddLenHead 是在数据的头部增加长度数据，用以在流式输出的连接中传输不粘包的数据

func GetData

func GetData(data []byte) ([]byte, error)

GetData 是从数据中获取真正的数据分片，如果数据并没有使用 AddLenHead 操作过，则该函数不能正确工作

func NewDataReader

func NewDataReader(conn DeadlineReader) (io.ReadCloser, error)

func NewDataWriter

func NewDataWriter(conn io.Writer) (io.Writer, error)

Types

type DeadlineReader

type DeadlineReader interface {
	Read(b []byte) (n int, err error)
	SetReadDeadline(t time.Time) error
}

DeadlineReader 是 io.Reader 加上 SetReadDeadline 方法的接口