Function newFrameReader

sockjsclient/xhr.go:336–341

(r io.Reader, timeout time.Duration)

}

func newFrameReader(r io.Reader, timeout time.Duration) *frameReader {
	return &frameReader{
		r:       bufio.NewReader(r),
		timeout: timeout,
	}
}

func (fr *frameReader) Read(p []byte) (int, error) {
	fr.once.Do(fr.readFrame)