Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 121 - 130 of 1,115 for receive (0.06 seconds)

  1. cmd/iam-object-store.go

    	ch := make(chan itemOrErr[string])
    
    	go func() {
    		defer xioutil.SafeClose(ch)
    
    		// Allocate new results channel to receive ObjectInfo.
    		objInfoCh := make(chan itemOrErr[ObjectInfo])
    
    		if err := objAPI.Walk(ctx, minioMetaBucket, pathPrefix, objInfoCh, WalkOptions{}); err != nil {
    			select {
    			case ch <- itemOrErr[string]{Err: err}:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 26.6K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

              startupTimers.put(service, Stopwatch.createStarted());
            }
          } finally {
            monitor.leave();
          }
        }
    
        /**
         * Marks the {@link State} as ready to receive transitions. Returns true if no transitions have
         * been observed yet.
         */
        void markReady() {
          monitor.enter();
          try {
            if (!transitioned) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 17:49:12 GMT 2025
    - 33.2K bytes
    - Click Count (1)
  3. guava/src/com/google/common/util/concurrent/ServiceManager.java

              startupTimers.put(service, Stopwatch.createStarted());
            }
          } finally {
            monitor.leave();
          }
        }
    
        /**
         * Marks the {@link State} as ready to receive transitions. Returns true if no transitions have
         * been observed yet.
         */
        void markReady() {
          monitor.enter();
          try {
            if (!transitioned) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 17:49:12 GMT 2025
    - 32.9K bytes
    - Click Count (0)
  4. docs/changelogs/changelog_4x.md

        receiving stream to process it.
    
        This change may increase OkHttp's memory use for applications that make many concurrent HTTP
        calls and that can receive data faster than they can process it. Previously, OkHttp limited
        HTTP/2 to 16 MiB of unacknowledged data per connection. With this fix there is a limit of 16 MiB
        of unacknowledged data per stream and no per-connection limit.
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Apr 17 13:25:31 GMT 2024
    - 25.2K bytes
    - Click Count (0)
  5. docs/changelogs/changelog_2x.md

        `BufferedSink` and a `ResponseBody` as an Okio `BufferedSource`. Standard
        `InputStream` and `OutputStream` access is also available.
    
     *  **New Call and Callback types** execute requests and receive their
        responses. Both types of calls can be canceled via the `Call` or the
        `OkHttpClient`.
    
     *  **URLConnection support has moved to the okhttp-urlconnection module.**
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sun Feb 06 02:19:09 GMT 2022
    - 26.6K bytes
    - Click Count (0)
  6. README.md

    ![ReDoc](https://fastapi.tiangolo.com/img/index/index-02-redoc-simple.png)
    
    ## Example upgrade
    
    Now modify the file `main.py` to receive a body from a `PUT` request.
    
    Declare the body using standard Python types, thanks to Pydantic.
    
    ```Python hl_lines="4  9-12  25-27"
    from typing import Union
    
    from fastapi import FastAPI
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Thu Dec 25 11:01:37 GMT 2025
    - 26.4K bytes
    - Click Count (0)
  7. docs/en/docs/alternatives.md

    Falcon is another high performance Python framework, it is designed to be minimal, and work as the foundation of other frameworks like Hug.
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Oct 11 17:48:49 GMT 2025
    - 23.6K bytes
    - Click Count (0)
  8. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnup/goals/PluginUpgradeStrategy.java

                        // Add plugin management based on effective model analysis
                        // Note: pluginsNeedingManagement only contains entries for POMs that should receive plugin
                        // management
                        // (i.e., the "last local parent" for each plugin that needs management)
                        Set<String> pluginsForThisPom = pluginsNeedingManagement.get(pomPath);
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Tue Nov 18 18:03:26 GMT 2025
    - 37K bytes
    - Click Count (0)
  9. fastapi/applications.py

                self.add_route(self.redoc_url, redoc_html, include_in_schema=False)
    
        async def __call__(self, scope: Scope, receive: Receive, send: Send) -> None:
            if self.root_path:
                scope["root_path"] = self.root_path
            await super().__call__(scope, receive, send)
    
        def add_api_route(
            self,
            path: str,
            endpoint: Callable[..., Any],
            *,
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 21:25:59 GMT 2025
    - 176.3K bytes
    - Click Count (0)
  10. CREDITS

    reinstated, you do not qualify to receive new licenses for the same
    material under section 10.
    
      9. Acceptance Not Required for Having Copies.
    
      You are not required to accept this License in order to receive or
    run a copy of the Program.  Ancillary propagation of a covered work
    occurring solely as a consequence of using peer-to-peer transmission
    to receive a copy likewise does not require acceptance.  However,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Mar 13 05:29:51 GMT 2025
    - 1.8M bytes
    - Click Count (0)
Back to Top