///

/// tip

By declaring `response_class=HTMLResponse` the docs UI will be able to know that the response will be HTML.

///

/// note | Technical Details

You could also use `from starlette.templating import Jinja2Templates`.

                        request.setOpenTimeout(r >> 16 & 0xFFFF);
                    }

                    try {
                        th.send(request, response, RequestParam.NO_RETRY);
                        n = response.getDataLength();
                    } catch (final CIFSException e) {
                        throw SmbException.wrap(e);
                    }
                }

        public TestCorsHandler(String name) {
            this.name = name;
        }

        @Override
        public void process(String origin, ServletRequest request, ServletResponse response) {
            // Test implementation - no operation
        }

        public String getName() {
            return name;
        }
    }

///

Then we can create an `AsyncClient` with the app, and send async requests to it, using `await`.

{* ../../docs_src/async_tests/app_a_py310/test_main.py hl[9:12] *}

This is the equivalent to:

```Python
response = client.get('/')
```

...that we used to make our requests with the `TestClient`.

/// tip

Note that we're using async/await with the new `AsyncClient` - the request is asynchronous.

///

        "event": {"type": "string"},
        "id": {"type": "string"},
        "retry": {"type": "integer", "minimum": 0},
    },
}


class EventSourceResponse(StreamingResponse):
    """Streaming response with `text/event-stream` media type.

    Use as `response_class=EventSourceResponse` on a *path operation* that uses `yield`
    to enable Server Sent Events (SSE) responses.

        client.setInitParameterMap(params);
    }

    /**
     * Executes the request with retry logic.
     * @param request The request data.
     * @return The response data.
     */
    @Override
    public ResponseData execute(final RequestData request) {
        if (listener != null) {
            listener.onRequestStart(this, request);
        }

ption":"","kibanaSavedObjectMeta":{"searchSourceJSON":"{\"query\":{\"query\":\"\",\"language\":\"kuery\"},\"filter\":[],\"indexRefName\":\"kibanaSavedObjectMeta.searchSourceJSON.index\"}"},"title":"average-response-time","uiStateJSON":"{}","version":1,"visState":"{\"title\":\"average-response-time\",\"type\":\"area\",\"params\":{\"type\":\"area\",\"grid\":{\"categoryLines\":false},\"categoryAxes\":[{\"id\":\"CategoryAxis-1\",\"type\":\"category\",\"position\":\"bottom\",\"show\":true,\"style\":{...

            // Note: ptype = 2 (RESPONSE) so it's safe to verify
            verify(mockBuffer).enc_ndr_small(DcerpcConstants.RPC_PT_RESPONSE);
        }
    }

    @Nested
    @DisplayName("Message Decoding Tests")
    class MessageDecodingTests {

        @Test
        @DisplayName("decode should handle RESPONSE ptype correctly")

        in 100..199 -> "Informational"
        in 200..299 -> "OK"
        in 300..399 -> "Redirection"
        in 400..499 -> "Client Error"
        in 500..599 -> "Server Error"
        else -> "Mock Response"
      }
    return apply { status = "HTTP/1.1 $code $reason" }
  }

  fun clearHeaders() =
    apply {
      headersBuilder = Headers.Builder()
    }

  fun addHeader(header: String) =

    }

    @Test
    @DisplayName("SMB version detection via flag or response type")
    void isSMB2_variants() throws Exception {
        // 1) smb2 flag set
        setField(transport, "smb2", true);
        assertTrue(transport.isSMB2());

        // 2) smb2 false but negotiated is SMB2 response
        setField(transport, "smb2", false);