ws

Documentation

Index

• type ReaderWriter
  • func NewClientReaderWriter(rqstpath string, headers http.Header) (wsrw *ReaderWriter, resp *http.Response, err error)
  • func NewServerReaderWriter(w http.ResponseWriter, r *http.Request) (wsrw *ReaderWriter, err error)
  • func (wsrw *ReaderWriter) CanRead() bool
  • func (wsrw *ReaderWriter) CanWrite() bool
  • func (wsrw *ReaderWriter) Close() (err error)
  • func (wsrw *ReaderWriter) Flush() (err error)
  • func (wsrw *ReaderWriter) LocalAddr() string
  • func (wsrw *ReaderWriter) Print(a ...interface{}) (err error)
  • func (wsrw *ReaderWriter) Println(a ...interface{}) (err error)
  • func (wsrw *ReaderWriter) Read(p []byte) (n int, err error)
  • func (wsrw *ReaderWriter) ReadAll() (s string, err error)
  • func (wsrw *ReaderWriter) ReadRune() (r rune, size int, err error)
  • func (wsrw *ReaderWriter) Readlines() (lines []string, err error)
  • func (wsrw *ReaderWriter) Readln() (s string, err error)
  • func (wsrw *ReaderWriter) RemoteAddr() string
  • func (wsrw *ReaderWriter) Seek(offset int64, whence int) (n int64, err error)
  • func (wsrw *ReaderWriter) SetMaxRead(maxlen int64) (err error)
  • func (wsrw *ReaderWriter) Write(p []byte) (n int, err error)
  • func (wsrw *ReaderWriter) WriteRune(r rune) (size int, err error)

Types

type ReaderWriter

type ReaderWriter struct {
	MaxRead int64
	// contains filtered or unexported fields
}

ReaderWriter - struct

func NewClientReaderWriter

func NewClientReaderWriter(rqstpath string, headers http.Header) (wsrw *ReaderWriter, resp *http.Response, err error)

func NewServerReaderWriter

func NewServerReaderWriter(w http.ResponseWriter, r *http.Request) (wsrw *ReaderWriter, err error)

NewServerReaderWriter - instance

func (*ReaderWriter) CanRead

func (wsrw *ReaderWriter) CanRead() bool

CanRead - can Read

func (*ReaderWriter) CanWrite

func (wsrw *ReaderWriter) CanWrite() bool

CanWrite - can Write

func (*ReaderWriter) Close

func (wsrw *ReaderWriter) Close() (err error)

Close - refer io.Closer

func (*ReaderWriter) Flush

func (wsrw *ReaderWriter) Flush() (err error)

Flush - flush invoke done onmessage

func (*ReaderWriter) LocalAddr

func (wsrw *ReaderWriter) LocalAddr() string

func (*ReaderWriter) Print

func (wsrw *ReaderWriter) Print(a ...interface{}) (err error)

Print - refer to fmt.Fprint

func (*ReaderWriter) Println

func (wsrw *ReaderWriter) Println(a ...interface{}) (err error)

Println - refer to fmt.Fprintln

func (*ReaderWriter) Read

func (wsrw *ReaderWriter) Read(p []byte) (n int, err error)

Read - refer io.Reader

func (*ReaderWriter) ReadAll

func (wsrw *ReaderWriter) ReadAll() (s string, err error)

ReadAll - return all read content as string

func (*ReaderWriter) ReadRune

func (wsrw *ReaderWriter) ReadRune() (r rune, size int, err error)

ReadRune - refer to io.RuneReader

func (*ReaderWriter) Readlines

func (wsrw *ReaderWriter) Readlines() (lines []string, err error)

Readlines - return lines []string slice

func (*ReaderWriter) Readln

func (wsrw *ReaderWriter) Readln() (s string, err error)

Readln - read single line

func (*ReaderWriter) RemoteAddr

func (wsrw *ReaderWriter) RemoteAddr() string

func (*ReaderWriter) Seek

func (wsrw *ReaderWriter) Seek(offset int64, whence int) (n int64, err error)

Seek - empty implementation refer to iorw.Reader

func (*ReaderWriter) SetMaxRead

func (wsrw *ReaderWriter) SetMaxRead(maxlen int64) (err error)

SetMaxRead - set max read implementation for Reader interface compliance

func (*ReaderWriter) Write

func (wsrw *ReaderWriter) Write(p []byte) (n int, err error)

Write - refer io.Writer

func (*ReaderWriter) WriteRune

func (wsrw *ReaderWriter) WriteRune(r rune) (size int, err error)

WriteRune - refer to bufio.Writer - WriteRune