reactor

Documentation

Index

• Constants
• Variables
• type Stream
  • func CreateWithRWC(r io.Reader, w io.Writer, c io.Closer) *Stream
  • func New(r io.ReadWriteCloser) *Stream
  • func (s *Stream) Close()
  • func (s *Stream) DataListener(listener func([]byte))
  • func (s *Stream) OnConnectionLost(listener func(reason error))
  • func (s *Stream) ReadSync(p []byte, timeout time.Duration) (err error)
  • func (s *Stream) Write(p []byte) (n int, err error)

Constants

const (
	ModeSync = iota
	ModeAsync
)

Variables

var (
	TimeoutErr = errors.New("timeout")
)

Types

type Stream

type Stream struct {
	io.Reader
	io.Writer
	io.Closer
	// contains filtered or unexported fields
}

func CreateWithRWC

func CreateWithRWC(r io.Reader, w io.Writer, c io.Closer) *Stream

func New

func New(r io.ReadWriteCloser) *Stream

func (*Stream) Close

func (s *Stream) Close()

func (*Stream) DataListener

func (s *Stream) DataListener(listener func([]byte))

func (*Stream) OnConnectionLost

func (s *Stream) OnConnectionLost(listener func(reason error))

func (*Stream) ReadSync

func (s *Stream) ReadSync(p []byte, timeout time.Duration) (err error)

阻塞读取 p 数据 timeout 超时间隔 err 超时返回

func (*Stream) Write

func (s *Stream) Write(p []byte) (n int, err error)