- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 194 for broken (0.36 seconds)
-
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) -
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) -
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) -
src/main/java/jcifs/SmbTransportPool.java
* * @param dc the domain controller address * @param tc the CIFS context containing credentials * @throws CIFSException if an error occurs during authentication * @deprecated functionality is broken and will be removed at some point, * use actual Active Directory authentication instead */ @Deprecated void logon(CIFSContext tc, Address dc) throws CIFSException; /**Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 7.5K bytes - Click Count (0) -
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) -
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
// Log after all static init is finished; if an installed logger uses any Futures methods, it // shouldn't break in cases where reflection is missing/broken. if (thrownReflectionFailure != null) { log.get().log(Level.SEVERE, "SafeAtomicHelper is broken!", thrownReflectionFailure); } } AggregateFutureState(int remainingFutures) { this.remainingField = remainingFutures; }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 8.5K bytes - Click Count (0) -
src/main/java/jcifs/https/Handler.java
* capabilities to the default HTTPS handler. This acts as a wrapper, * handling authentication and passing control to the underlying * stream handler. * * @deprecated {@link NtlmHttpURLConnection} is broken by design. */ @Deprecated public class Handler extends jcifs.http.Handler { /** * The default HTTPS port (<code>443</code>). */ public static final int DEFAULT_HTTPS_PORT = 443;Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 1.9K bytes - Click Count (0) -
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) -
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) -
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)