Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 172 for broken (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. guava-tests/test/com/google/common/collect/AbstractSequentialIteratorTest.java

      }
    
      public void testBroken() {
        Iterator<Object> broken = new BrokenAbstractSequentialIterator();
        assertTrue(broken.hasNext());
        // We can't retrieve even the known first element:
        assertThrows(SomeUncheckedException.class, broken::next);
        assertThrows(SomeUncheckedException.class, broken::next);
      }
    
      private static Iterator<Integer> newDoubler(int first, int last) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 4.7K bytes
    - Click Count (0)
  4. 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)
  5. guava/src/com/google/common/collect/AbstractBiMap.java

        inverse.delegate.clear();
        Entry<K, V> broken = null;
        Iterator<Entry<K, V>> itr = this.delegate.entrySet().iterator();
        while (itr.hasNext()) {
          Entry<K, V> entry = itr.next();
          K k = entry.getKey();
          V v = entry.getValue();
          K conflict = inverse.delegate.putIfAbsent(v, k);
          if (conflict != null) {
            broken = entry;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Sep 22 15:50:50 GMT 2025
    - 14.3K bytes
    - Click Count (0)
  6. src/main/java/jcifs/internal/smb2/lock/Smb2OplockBreakNotification.java

    import jcifs.internal.util.SMBUtil;
    import jcifs.util.Hexdump;
    
    /**
     * SMB2 Oplock Break notification message. This server-initiated message notifies the client
     * that an opportunistic lock must be broken due to conflicting access from another client.
     *
     * @author mbechler
     *
     */
    public class Smb2OplockBreakNotification extends ServerMessageBlock2Response {
    
        private byte oplockLevel;
        private byte[] fileId;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 2.9K bytes
    - Click Count (0)
  7. src/main/java/jcifs/smb/SmbWatchHandleImpl.java

         * @see jcifs.SmbWatchHandle#watch()
         */
        @Override
        public List<FileNotifyInformation> watch() throws CIFSException {
            if (!this.handle.isValid()) {
                throw new SmbException("Watch was broken by tree disconnect");
            }
            try (SmbTreeHandleImpl th = this.handle.getTree()) {
    
                CommonServerMessageBlockRequest req;
                NotifyResponse resp = null;
                if (th.isSMB2()) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/CertificatePinner.kt

     *
     * The easiest way to pin a host is turn on pinning with a broken configuration and read the
     * expected configuration when the connection fails. Be sure to do this on a trusted network, and
     * without man-in-the-middle tools like [Charles][charles] or [Fiddler][fiddler].
     *
     * For example, to pin `https://publicobject.com`, start with a broken configuration:
     *
     * ```java
     * String hostname = "publicobject.com";
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 14.2K bytes
    - Click Count (1)
  9. android/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
    - 11.5K bytes
    - Click Count (0)
  10. tests/test_dependency_yield_scope_websockets.py

        with pytest.raises(
            FastAPIError,
            match='The dependency "get_named_func_session" has a scope of "request", it cannot depend on dependencies with scope "function"',
        ):
    
            @app.websocket("/broken-scope")
            async def get_broken(
                websocket: WebSocket, sessions: BrokenSessionsDep
            ) -> Any:  # pragma: no cover
                pass
    
    
    def test_named_function_scope() -> None:
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Wed Dec 17 21:25:59 GMT 2025
    - 6K bytes
    - Click Count (0)
Back to Top