Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1861 - 1870 of 2,109 for collect (0.04 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/WebSocket.kt

       */
      fun cancel()
    
      fun interface Factory {
        /**
         * Creates a new web socket and immediately returns it. Creating a web socket initiates an
         * asynchronous process to connect the socket. Once that succeeds or fails, `listener` will be
         * notified. The caller must either close or cancel the returned web socket when it is no longer
         * in use.
         */
        fun newWebSocket(
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb/SmbNamedPipe.java

     * <code>WriteFile</code>, and <code>CloseFile</code> interface was
     * being used.
     * </td>
     * </tr>
     * </table>
     *
     * <p>
     * See <a href="../../../pipes.html">Using jCIFS to Connect to Win32
     * Named Pipes</a> for a detailed description of how to use jCIFS with
     * Win32 Named Pipe server processes.
     *
     */
    
    public class SmbNamedPipe extends SmbFile implements SmbPipeResource {
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  3. src/main/java/jcifs/internal/smb2/rdma/RdmaTransport.java

                if (rdmaConnection != null && rdmaConnection.isConnected()) {
                    return;
                }
    
                try {
                    rdmaConnection =
                            rdmaProvider.connect(delegate.getRemoteAddress().getHostAddress(), delegate.getContext().getConfig().getRdmaPort());
                    log.info("RDMA connection established to {}", delegate.getRemoteAddress());
                } catch (IOException e) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  4. docs/en/docs/advanced/websockets.md

    There you can set:
    
    * The "Item ID", used in the path.
    * The "Token" used as a query parameter.
    
    /// tip
    
    Notice that the query `token` will be handled by a dependency.
    
    ///
    
    With that you can connect the WebSocket and then send and receive messages:
    
    <img src="/img/tutorial/websockets/image05.png">
    
    ## Handling disconnections and multiple clients { #handling-disconnections-and-multiple-clients }
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:15:41 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

            }
            // We reschedule ourselves with a lock held for two reasons. 1. we want to make sure that
            // cancel calls cancel on the correct future. 2. we want to make sure that the assignment
            // to currentFuture doesn't race with itself so that currentFuture is assigned in the
            // correct order.
            Throwable scheduleFailure = null;
            Cancellable toReturn;
            lock.lock();
            try {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  6. cmd/signature-v2_test.go

    		{
    			authString:    "NoV2Prefix",
    			expectedError: ErrSignatureVersionNotSupported,
    		},
    		// Test case - 3.
    		// Test case with missing parts in the Auth string.
    		// below is the correct format of V2 Authorization header.
    		// Authorization = "AWS" + " " + AWSAccessKeyId + ":" + Signature
    		{
    			authString:    signV2Algorithm,
    			expectedError: ErrMissingFields,
    		},
    		// Test case - 4.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/exception/ScriptEngineExceptionTest.java

            assertTrue(exception instanceof Exception);
            assertTrue(exception instanceof Throwable);
        }
    
        public void test_serialization() {
            // Test that the exception has the correct serialVersionUID field
            ScriptEngineException exception = new ScriptEngineException("Serialization test");
    
            // Verify the exception can be created and basic properties work
            assertNotNull(exception);
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  8. src/test/java/jcifs/internal/smb1/ServerMessageBlockTest.java

                // This test verifies actual behavior
                testBlock.setFlags((byte) 0x00);
                assertFalse(testBlock.isResolveInDfs());
    
                // The correct implementation should check flags2, not flags
                testBlock.addFlags2(SmbConstants.FLAGS2_RESOLVE_PATHS_IN_DFS);
                // But due to the bug, this still returns false
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 36.2K bytes
    - Viewed (0)
  9. docs/en/docs/tutorial/dependencies/dependencies-with-yield.md

    You can have sub-dependencies and "trees" of sub-dependencies of any size and shape, and any or all of them can use `yield`.
    
    **FastAPI** will make sure that the "exit code" in each dependency with `yield` is run in the correct order.
    
    For example, `dependency_c` can have a dependency on `dependency_b`, and `dependency_b` on `dependency_a`:
    
    {* ../../docs_src/dependencies/tutorial008_an_py39.py hl[6,14,22] *}
    
    And all of them can use `yield`.
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:15:41 UTC 2025
    - 12.7K bytes
    - Viewed (0)
  10. CHANGELOG/CHANGELOG-1.9.md

    * This fix prevents a GCE PD volume from being mounted if the udev device link is stale and tries to correct the link. ([#66832](https://github.com/kubernetes/kubernetes/pull/66832), [@msau42](https://github.com/msau42))
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Tue Nov 16 10:46:27 UTC 2021
    - 313.7K bytes
    - Viewed (0)
Back to top