fun request(): Request

  /**
   * Immediately and violently release resources held by this event source. This does nothing if
   * the event source has already been closed or canceled.
   */
  fun cancel()

  fun interface Factory {
    /**
     * Creates a new event source and immediately returns it. Creating an event source initiates an

from uuid import UUID

from annotated_doc import Doc
from fastapi.exceptions import PydanticV1NotSupportedError
from fastapi.types import IncEx
from pydantic import BaseModel
from pydantic.color import Color
from pydantic.networks import AnyUrl, NameEmail
from pydantic.types import SecretBytes, SecretStr
from pydantic_core import PydanticUndefinedType

from ._compat import (
    Url,

   * should return immediately. Responses returned after shutdown will not be transmitted: their
   * socket connections have already been closed.
   */
  public open override fun close() {}

                    body=new_translation_message,
                )
                logging.info(f"Notified in comment: {comment.url}")
        elif pr.state == "closed" or approved_label in label_strs:
            logging.info(f"Already approved or closed PR #{pr.number}")
            if already_done_comment:
                logging.info(

As we cannot just isolate them and "mount" them independently of the rest, the *path operations* are "cloned" (re-created), not included directly.

///

## Check the automatic API docs { #check-the-automatic-api-docs }

Now, run your app:

<div class="termy">

```console
$ fastapi dev app/main.py

<span style="color: green;">INFO</span>:     Uvicorn running on http://127.0.0.1:8000 (Press CTRL+C to quit)
```

    @Override
    public Optional<Boolean> rawStreams() {
        return returnFirstPresentOrEmpty(Options::rawStreams);
    }

    @Override
    public Optional<String> color() {
        return returnFirstPresentOrEmpty(Options::color);
    }

    @Override
    public Optional<Boolean> offline() {
        return returnFirstPresentOrEmpty(Options::offline);
    }

    @Override

            // if (endpoint != null) {
            //     endpoint.close();
            // }
        } finally {
            state = RdmaConnectionState.CLOSED;
        }

        log.debug("DiSNI RDMA connection closed");
    }

      with:
        repo-token: ${{ secrets.GITHUB_TOKEN }}
        stale-issue-message: "This issue has been automatically marked as stale because it has been open 360 days with no activity. Remove stale label or comment or this will be closed in 180 days"
        days-before-stale: 360
        days-before-close: 180
        stale-issue-label: "status:stale"
        exempt-issue-labels: 'type:feature,type:with reproduction steps,type:has pull request'

        assertThrows(SmbUnsupportedOperationException.class, sut::watch);
        verify(tree, times(1)).close();
    }

    // SMB1 path: on error code 0x10B the handle should be marked closed
    @Test
    @DisplayName("watch() SMB1 marks handle closed on error 0x10B")
    void watch_smb1_marksClosed_onError10B() throws Exception {
        NotifyResponse resp = mock(NotifyResponse.class);
        when(resp.isReceived()).thenReturn(true);

import okio.Buffer
import okio.Socket

/**
 * An HTTP response. Instances of this class are not immutable: the response body is a one-shot
 * value that may be consumed only once and then closed. All other properties are immutable.
 *
 * This class implements [Closeable]. Closing it simply closes its response body. See
 * [ResponseBody] for an explanation and examples.
 */
class Response internal constructor(