Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 163 for broker (0.04 seconds)

  1. docs/en/docs/css/custom.css

      margin-bottom: 2em;
    }
    
    /* Screenshots */
    /*
    Simulate a browser window frame.
    Inspired by Termynal's CSS tricks with modifications
    */
    
    .screenshot {
      display: block;
      background-color: #d3e0de;
      border-radius: 4px;
      padding: 45px 5px 5px;
      position: relative;
      -webkit-box-sizing: border-box;
              box-sizing: border-box;
    }
    
    .screenshot img {
      display: block;
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Mon Mar 23 13:56:46 GMT 2026
    - 6.6K bytes
    - Click Count (0)
  2. tests/test_dependency_after_yield_raise.py

    
    def broken_dep() -> Any:
        yield "s"
        raise ValueError("Broken after yield")
    
    
    app = FastAPI()
    
    
    @app.get("/catching")
    def catching(d: Annotated[str, Depends(catching_dep)]) -> Any:
        raise CustomError("Simulated error during streaming")
    
    
    @app.get("/broken")
    def broken(d: Annotated[str, Depends(broken_dep)]) -> Any:
        return {"message": "all good?"}
    
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Wed Dec 17 21:25:59 GMT 2025
    - 1.7K bytes
    - Click Count (0)
  3. tests/test_dependency_after_yield_streaming.py

        def iter_data():
            yield from session
    
        return StreamingResponse(iter_data())
    
    
    @app.get("/broken-session-data")
    def get_broken_session_data(session: BrokenSessionDep) -> Any:
        return list(session)
    
    
    @app.get("/broken-session-stream")
    def get_broken_session_stream(session: BrokenSessionDep) -> Any:
        def iter_data():
            yield from session
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Wed Dec 17 21:25:59 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

        //            (__)\       )\/\
        //                ||----w |
        //                ||     ||
        Runnable state = get();
        Blocker blocker = null;
        while (state instanceof Blocker || state == PARKED) {
          if (state instanceof Blocker) {
            blocker = (Blocker) state;
          }
          spinCount++;
          if (spinCount > MAX_BUSY_WAIT_SPINS) {
            /*
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 10K bytes
    - Click Count (0)
  5. src/main/webapp/js/index.js

        if ($icon.length > 0) {
          $icon.removeClass("fa fa-search").addClass("spinner-border spinner-border-sm");
        }
        setTimeout(function() {
          $searchButton.prop("disabled", false);
          var $spinner = $searchButton.find(".spinner-border");
          if ($spinner.length > 0) {
            $spinner.removeClass("spinner-border spinner-border-sm").addClass("fa fa-search");
          }
        }, BUTTON_DISABLE_DURATION);
        return true;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Mon Feb 23 08:03:44 GMT 2026
    - 2.2K bytes
    - Click Count (0)
  6. docs/en/docs/css/termynal.css

        font-family: var(--md-code-font-family), 'Roboto Mono', 'Fira Mono', Consolas, Menlo, Monaco, 'Courier New', Courier, monospace;
        border-radius: 4px;
        padding: 75px 45px 35px;
        position: relative;
        -webkit-box-sizing: border-box;
                box-sizing: border-box;
        /* Custom line-height */
        line-height: 1.2;
    }
    
    [data-termynal]:before {
        content: '';
        position: absolute;
        top: 15px;
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sun Nov 23 09:27:40 GMT 2025
    - 2.2K bytes
    - Click Count (0)
  7. tests/test_dependency_after_yield_websockets.py

    @app.websocket("/ws")
    async def websocket_endpoint(websocket: WebSocket, session: SessionDep):
        await websocket.accept()
        for item in session:
            await websocket.send_text(f"{item}")
    
    
    @app.websocket("/ws-broken")
    async def websocket_endpoint_broken(websocket: WebSocket, session: BrokenSessionDep):
        await websocket.accept()
        for item in session:
            await websocket.send_text(f"{item}")  # pragma no cover
    
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Wed Dec 17 21:25:59 GMT 2025
    - 2K bytes
    - Click Count (0)
  8. guava/src/com/google/common/collect/Comparators.java

      }
    
      /**
       * Returns a {@code Collector} that returns the {@code k} smallest (relative to the specified
       * {@code Comparator}) input elements, in ascending order, as an unmodifiable {@code List}. Ties
       * are broken arbitrarily.
       *
       * <p>For example:
       *
       * {@snippet :
       * Stream.of("foo", "quux", "banana", "elephant").collect(least(2, comparingInt(String::length)))
       * // returns {"foo", "quux"}
       * }
       *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 10.9K bytes
    - Click Count (0)
  9. src/main/webapp/css/chat.css

    }
    
    .card-footer #chatInput {
        resize: none;
        max-height: 150px;
        overflow-y: auto;
        border-radius: 8px 0 0 8px;
        border: 1px solid #dfe1e6;
        transition: border-color 0.2s ease, box-shadow 0.2s ease;
    }
    
    .card-footer #chatInput:focus {
        border-color: #0052cc;
        box-shadow: 0 0 0 2px rgba(0, 82, 204, 0.2);
    }
    
    .card-footer #sendBtn {
        display: flex;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Mar 15 06:21:57 GMT 2026
    - 19.4K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

        // waiting for the slow interrupting thread to complete Thread.interrupt
        awaitBlockedOnInstanceOf(runner, InterruptibleTask.Blocker.class);
    
        Blocker blocker = (Blocker) LockSupport.getBlocker(runner);
        Thread owner = blocker.getOwner();
        assertThat(owner).isSameInstanceAs(interrupter);
    
        slowChannel.exitClose.countDown(); // release the interrupter
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.2K bytes
    - Click Count (0)
Back to Top