Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 361 - 370 of 491 for ccancel (0.05 seconds)

  1. docs/en/docs/tutorial/extra-models.md

    ///
    
    ## Reduce duplication { #reduce-duplication }
    
    Reducing code duplication is one of the core ideas in **FastAPI**.
    
    As code duplication increments the chances of bugs, security issues, code desynchronization issues (when you update in one place but not in the others), etc.
    
    And these models are all sharing a lot of the data and duplicating attribute names and types.
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Dec 20 15:55:38 GMT 2025
    - 6.9K bytes
    - Click Count (0)
  2. internal/event/target/mqtt.go

    	_, err := target.isActive()
    	if err != nil {
    		return err
    	}
    
    	eventData, err := target.store.Get(key)
    	if err != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(err) {
    			return nil
    		}
    		return err
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 8.2K bytes
    - Click Count (0)
  3. cmd/handler-api.go

    		t.staleUploadsCleanupInterval = cfg.StaleUploadsCleanupInterval
    
    		// signal that cleanup interval has changed
    		select {
    		case staleUploadsCleanupIntervalChangedCh <- struct{}{}:
    		default: // in case the channel is blocked...
    		}
    	}
    }
    
    func (t *apiConfig) odirectEnabled() bool {
    	t.mu.RLock()
    	defer t.mu.RUnlock()
    
    	return t.enableODirect
    }
    
    func (t *apiConfig) shouldGzipObjects() bool {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  4. src/test/java/jcifs/internal/smb2/io/Smb2WriteResponseTest.java

                int bytesRead = response.readBytesWireFormat(buffer, 0);
    
                assertEquals(16, bytesRead); // Structure size + reserved (4) + count (4) + remaining (4) + channel info (4)
                assertEquals(1024, response.getCount());
                assertEquals(512, response.getRemaining());
            }
    
            @Test
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 15.9K bytes
    - Click Count (0)
  5. docs/changelogs/changelog_4x.md

        }
        ```
    
     *  New: Upgrade to Okio 2.4.3.
    
        ```kotlin
        implementation("com.squareup.okio:okio:2.4.3")
        ```
    
     *  Fix: Limit retry attempts for HTTP/2 `REFUSED_STREAM` and `CANCEL` failures.
     *  Fix: Retry automatically when incorrectly sharing a connection among multiple hostnames. OkHttp
        shares connections when hosts share both IP addresses and certificates, such as `squareup.com`
    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)
  6. guava/src/com/google/common/io/Files.java

        try {
          RandomAccessFile raf =
              closer.register(new RandomAccessFile(file, mode == MapMode.READ_ONLY ? "r" : "rw"));
          FileChannel channel = closer.register(raf.getChannel());
          return channel.map(mode, 0, size == -1 ? channel.size() : size);
        } catch (Throwable e) {
          throw closer.rethrow(e);
        } finally {
          closer.close();
        }
      }
    
      /**
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Sep 25 20:24:13 GMT 2025
    - 32.8K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Response.kt

       * call this without consuming the complete response body, any remaining bytes in the response
       * body will be discarded before trailers are returned.
       *
       * If [Call.cancel] is called while this is blocking, this call will immediately throw.
       *
       * @throws IllegalStateException if the response is closed.
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon Jul 28 14:39:28 GMT 2025
    - 18.1K bytes
    - Click Count (0)
  8. src/main/java/jcifs/config/PropertyConfiguration.java

            String maxVersion = props.getProperty("jcifs.smb.client.maxVersion");
            if (minVersion != null || maxVersion != null) {
                initProtocolVersions(minVersion, maxVersion);
            }
    
            // Multi-Channel Configuration
            value = props.getProperty("jcifs.smb.client.useMultiChannel");
            if (value != null) {
                this.useMultiChannelExplicitlySet = true;
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sun Aug 24 00:49:49 GMT 2025
    - 13.3K bytes
    - Click Count (0)
  9. src/test/java/jcifs/internal/RequestTest.java

                return 1;
            }
    
            @Override
            public void setRequestCredits(int credits) {
                this.requestCredits = credits;
            }
    
            @Override
            public boolean isCancel() {
                return false;
            }
    
            // Methods from Message interface
            @Override
            public void retainPayload() {
                this.retainPayload = true;
            }
    
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 14.5K bytes
    - Click Count (0)
  10. kotlin-js-store/yarn.lock

      integrity sha512-7++dFhtcx3353uBaq8DDR4NuxBetBzC7ZQOhmTQInHEd6bSrXdiEyzCvG07Z44UYdLShWUyXt5M/yhz8ekcb1A==
    
    side-channel@^1.0.4:
      version "1.0.4"
      resolved "https://registry.yarnpkg.com/side-channel/-/side-channel-1.0.4.tgz#efce5c8fdc104ee751b25c58d4290011fa5ea2cf"
      integrity sha512-q5XPytqFEIKHkGdiMIrY10mvLRvnQh42/+GoBlFW3b2LXLE2xxJpZFdm94we0BaoV3RwJyGqg5wS7epxTv0Zvw==
      dependencies:
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Jul 22 12:28:51 GMT 2023
    - 87.4K bytes
    - Click Count (0)
Back to Top