Search Options

Results per page
Sort
Preferred Languages
Advance

Results 271 - 280 of 401 for Futures (0.09 sec)

  1. fastapi/openapi/utils.py

                    # explicit default status_code, and to extract it from them, instead of
                    # doing this inspection tricks, that would probably be in the future
                    # TODO: probably make status_code a default class attribute for all
                    # responses in Starlette
                    response_signature = inspect.signature(current_response_class.__init__)
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Sep 17 18:54:10 UTC 2024
    - 22.6K bytes
    - Viewed (0)
  2. internal/logger/target/kafka/kafka.go

    	// stop the replay go-routine.
    	if h.store != nil {
    		h.storeCtxCancel()
    	}
    
    	// Set logch to nil and close it.
    	// This will block all Send operations,
    	// and finish the existing ones.
    	// All future ones will be discarded.
    	h.logChMu.Lock()
    	xioutil.SafeClose(h.logCh)
    	h.logCh = nil
    	h.logChMu.Unlock()
    
    	if h.producer != nil {
    		h.producer.Close()
    		h.client.Close()
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  3. tensorflow/c/eager/parallel_device/parallel_device_lib.h

      // without sequencing those operations (first call `StartExecute` on each
      // parallel device, then call `Join` on each; even if some of the `Join`s
      // return a bad status the caller must run all of the `Join`s or any future
      // `StartExecute`s will deadlock).
      //
      // If `is_async=false` (constructor argument), `cancellation_manager` must
      // live until `Join` finishes. If `is_async=true` it must live until `Join` is
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Oct 21 04:14:14 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  4. docs/en/docs/deployment/https.md

    ### Certificate Renewal
    
    At some point in the future, each certificate would **expire** (about 3 months after acquiring it).
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 12K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt

          )
        }
    
        client.routeDatabase.failed(failedRoute)
      }
    
      /**
       * Track a failure using this connection. This may prevent both the connection and its route from
       * being used for future exchanges.
       */
      override fun trackFailure(
        call: RealCall,
        e: IOException?,
      ) {
        var noNewExchangesEvent = false
        lock.withLock {
          if (e is StreamResetException) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  6. docs/fr/docs/tutorial/path-params.md

    * Validation de données.
    * Annotations d'API et documentation automatique.
    
    Et vous n'avez besoin de le déclarer qu'une fois.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 10K bytes
    - Viewed (0)
  7. common/config/.golangci.yml

          - name: string-of-int
          - name: defer
            arguments:
              - - "call-chain"
          - name: unconditional-recursion
          - name: identical-branches
            # the following rules can be enabled in the future
            # - name: empty-lines
            # - name: confusing-results
            # - name: empty-block
            # - name: get-return
            # - name: confusing-naming
            # - name: unexported-naming
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 17:36:49 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/graph/AbstractStandardDirectedNetworkTest.java

      }
    
      // Element Mutation
    
      @Test
      public void addEdge_existingNodes() {
        assume().that(graphIsMutable()).isTrue();
    
        // Adding nodes initially for safety (insulating from possible future
        // modifications to proxy methods)
        addNode(N1);
        addNode(N2);
        assertThat(networkAsMutableNetwork.addEdge(N1, N2, E12)).isTrue();
        assertThat(network.edges()).contains(E12);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 02 18:21:29 UTC 2024
    - 20.8K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/graph/AbstractStandardDirectedNetworkTest.java

      }
    
      // Element Mutation
    
      @Test
      public void addEdge_existingNodes() {
        assume().that(graphIsMutable()).isTrue();
    
        // Adding nodes initially for safety (insulating from possible future
        // modifications to proxy methods)
        addNode(N1);
        addNode(N2);
        assertThat(networkAsMutableNetwork.addEdge(N1, N2, E12)).isTrue();
        assertThat(network.edges()).contains(E12);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 02 18:21:29 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  10. build-logic/documentation/src/main/groovy/gradlebuild/docs/GradleUserManualPlugin.java

            return excludedPackages;
        }
    
        // TODO: This doesn't really make sense to be part of the user manual generation, but it's so tied up into it
        // it's left here for a future project.
        private void generateDefaultImports(Project project, TaskContainer tasks, GradleDocumentationExtension extension) {
            List<String> excludedPackages = getDefaultExcludedPackages();
    
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Fri Mar 01 05:46:51 UTC 2024
    - 17.7K bytes
    - Viewed (0)
Back to top