mock

Documentation

Index

• type Stream
  • func NewStream(readBuffer, writeBuffer *bytes.Buffer) *Stream
  • func (s *Stream) Close() error
  • func (s *Stream) FullClose() error
  • func (s *Stream) Headers() p2p.Headers
  • func (s *Stream) Read(p []byte) (n int, err error)
  • func (s *Stream) SetReadErr(err error, checkmark int)
  • func (s *Stream) SetWriteErr(err error, checkmark int)
  • func (s *Stream) Write(p []byte) (n int, err error)

Types

type Stream

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

func NewStream

func NewStream(readBuffer, writeBuffer *bytes.Buffer) *Stream

func (*Stream) Close

func (s *Stream) Close() error

func (*Stream) FullClose

func (s *Stream) FullClose() error

func (*Stream) Headers

func (s *Stream) Headers() p2p.Headers

func (*Stream) Read

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

func (*Stream) SetReadErr

func (s *Stream) SetReadErr(err error, checkmark int)

func (*Stream) SetWriteErr

func (s *Stream) SetWriteErr(err error, checkmark int)

func (*Stream) Write

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