Method Write

nats_test.go:1816–1823

(p []byte)

}

func (mc *mockConn) Write(p []byte) (int, error) {
	if mc.failures < mc.temporaryFailures {
		mc.failures++
		return 0, &net.OpError{Op: "write", Net: "tcp", Err: errors.New("i/o timeout")}
	}
	mc.data = append(mc.data, p...)
	return len(p), nil
}

func (mc *mockConn) SetWriteDeadline(t time.Time) error { return nil }
func (mc *mockConn) Read(b []byte) (int, error)         { return 0, nil }