websocket/stream.go
func (t ObjectStream) ReadObject(v interface{}) error {
	err := t.conn.ReadJSON(v)
	if e, ok := err.(*websocket.CloseError); ok {
		if e.Code == websocket.CloseAbnormalClosure && e.Text == io.ErrUnexpectedEOF.Error() {
			// Suppress a noisy (but harmless) log message by
			// unwrapping this error.
			err = io.ErrUnexpectedEOF
		}
	}
	return err
}
func (t ObjectStream) ReadObject(v interface{}) error {
	err := t.conn.ReadJSON(v)
	if e, ok := err.(*websocket.CloseError); ok {
		if e.Code == websocket.CloseAbnormalClosure && e.Text == io.ErrUnexpectedEOF.Error() {
			// Suppress a noisy (but harmless) log message by
			// unwrapping this error.
			err = io.ErrUnexpectedEOF
		}
	}
	return err
}
func ( t ObjectStream ) ReadObject ( v interface { } ) error { err := t . conn . ReadJSON ( v ) if e , ok := err . ( * websocket . CloseError ) ; ok { if e . Code == websocket . CloseAbnormalClosure && e . Text == io . ErrUnexpectedEOF . Error ( ) { // Suppress a noisy (but harmless) log message by // unwrapping this error. err = io . ErrUnexpectedEOF } } return err }
// ReadObject implements jsonrpc2.ObjectStream.
ReadObject implements jsonrpc2 . ObjectStream .