Method fail

mcp/streamable.go:1739–1746

fail handles an asynchronous error while reading. If err is non-nil, it is terminal, and subsequent (or pending) Reads will fail. If err wraps ErrSessionMissing, the failure indicates that the session is no longer present on the server, and no final DELETE will be performed when closing the connec

(err error)

// longer present on the server, and no final DELETE will be performed when
// closing the connection.
func (c *streamableClientConn) fail(err error) {
	if err != nil {
		c.failOnce.Do(func() {
			c._failure = err
			close(c.failed)
		})
	}
}

func (c *streamableClientConn) failure() error {
	select {