assertThat(expected.errorCode).isEqualTo(ErrorCode.REFUSED_STREAM)
    }
  }

  @Test
  fun recoverFromOneInternalErrorRequiresNewConnection() {
    recoverFromOneHttp2ErrorRequiresNewConnection(ErrorCode.INTERNAL_ERROR)
  }

  @Test
  fun recoverFromOneCancelRequiresNewConnection() {
    recoverFromOneHttp2ErrorRequiresNewConnection(ErrorCode.CANCEL)
  }

    connection.newStream(headerEntries("b", "banana"), false)

    // Verify the peer received what was expected.
    assertThat(peer.takeFrame().type).isEqualTo(Http2.TYPE_HEADERS)
    assertThat(peer.takeFrame().errorCode).isEqualTo(ErrorCode.PROTOCOL_ERROR)
  }

  @Test fun pushPromiseStreamsAutomaticallyCancel() {
    // Write the mocking script.
    peer.sendFrame().settings(Settings())
    peer.acceptFrame() // ACK
    peer

        } else {
            final String errorCode = UUID.randomUUID().toString();
            message = escapeJsonKeyValue("error_code:", errorCode);
            if (logger.isDebugEnabled()) {
                logger.debug("[{}] {}", errorCode, stacktraceString.get().replace("\n", "\\n"));
            } else if (status >= 500) {
                logger.warn("[{}] {}", errorCode, t.getMessage());
            }
        }

                throw new IOException("Invalid payload size: " + size);
            }
            final int errorCode = Encdec.dec_uint32le(buffer, 9) & 0xFFFFFFFF;
            if (resp.getCommand() == ServerMessageBlock.SMB_COM_READ_ANDX
                    && (errorCode == 0 || errorCode == NtStatus.NT_STATUS_BUFFER_OVERFLOW)) {
                // overflow indicator normal for pipe

            return new ChatResult(session.getSessionId(), assistantMessage, sources);

        } catch (final LlmException e) {
            logger.warn("[RAG] LLM error during enhanced chat. sessionId={}, errorCode={}, error={}, elapsedTime={}ms",
                    session.getSessionId(), e.getErrorCode(), e.getMessage(), System.currentTimeMillis() - startTime, e);
            callback.onError("llm", e.getErrorCode());

			// since S3 only sends one Error XML response.
			if len(e.Errors) >= 1 {
				apiErr.Code = e.Errors[0].Reason
			}
		case *azcore.ResponseError:
			apiErr = APIError{
				Code:           e.ErrorCode,
				Description:    e.Error(),
				HTTPStatusCode: e.StatusCode,
			}
			// Add more other SDK related errors here if any in future.
		default:
			//nolint:gocritic