- Sort Score
- Num 10 results
- Language All
Results 441 - 450 of 2,699 for should (0.07 seconds)
-
okhttp/src/jvmTest/kotlin/okhttp3/internal/cache/DiskLruCacheTest.kt
assertThat(cache.size()).isEqualTo(10) // Cause the size to grow to 12 should evict 'A'. set("c", "c", "c") cache.flush() assertThat(cache.size()).isEqualTo(8) assertAbsent("a") assertValue("b", "bb", "bbbb") assertValue("c", "c", "c") // Causing the size to grow to 10 should evict nothing. set("d", "d", "d") cache.flush()
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Nov 01 12:18:11 GMT 2025 - 59.4K bytes - Click Count (0) -
cmd/object-api-utils_test.go
// but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU Affero General Public License for more details. // // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "bytes" "context" "encoding/hex" "fmt"
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 24.1K bytes - Click Count (0) -
internal/event/target/kafka.go
} if k.QueueDir != "" { if !filepath.IsAbs(k.QueueDir) { return errors.New("queueDir path should be absolute") } } if k.Version != "" { if _, err := sarama.ParseKafkaVersion(k.Version); err != nil { return err } } if k.BatchSize > 1 { if k.QueueDir == "" { return errors.New("batch should be enabled only if queue dir is enabled") } } if k.BatchCommitTimeout > 0 {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 13.6K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
val oldDelegate = timeout.delegate timeout.setDelegate(Timeout.NONE) oldDelegate.clearDeadline() oldDelegate.clearTimeout() } /** * The response body from a CONNECT should be empty, but if it is not then we should consume it * before proceeding. */ fun skipConnectBody(response: Response) { val contentLength = response.headersContentLength() if (contentLength == -1L) returnCreated: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 17.5K bytes - Click Count (7) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt
} catch (expected: IOException) { } server .url("/b") .toUrl() .openConnection() .getInputStream() // Should succeed. } /** * Throttle the request body by sleeping 500ms after every 3 bytes. With a 6-byte request, this * should yield one sleep for a total delay of 500ms. */ @Test fun throttleRequest() { assumeNotWindows() server.enqueue(
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Jul 03 13:16:34 GMT 2025 - 22.3K bytes - Click Count (0) -
.github/CONTRIBUTING.md
- OkHttp targets the intersection of RFC correct *and* widely implemented. Incorrect implementations that are very widely implemented e.g. a bug in Apache, Nginx, Google, Firefox should also be handled. Before your code can be accepted into the project you must also sign the [Individual Contributor License Agreement (CLA)][1].
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sun Mar 17 04:16:26 GMT 2019 - 1.4K bytes - Click Count (0) -
guava/src/com/google/common/reflect/Types.java
* refer only to types present under Android, so we could implement them in {@code * TypeVariableImpl} today. (We could probably then make {@code TypeVariableImpl} implement {@code * AnnotatedElement} so that we get partial compile-time checking.) * * <p>This workaround should be removed at a distant future time when <aCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Oct 31 19:34:24 GMT 2025 - 24.3K bytes - Click Count (0) -
android/guava/src/com/google/common/base/Verify.java
/** * Static convenience methods that serve the same purpose as Java language <a * href="https://docs.oracle.com/javase/8/docs/technotes/guides/language/assert.html">assertions</a>, * except that they are always enabled. These methods should be used instead of Java assertions * whenever there is a chance the check may fail "in real life". Example: * * {@snippet : * Bill bill = remoteService.getLastUnpaidBill(); *
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Mar 17 20:26:29 GMT 2025 - 18.3K bytes - Click Count (0) -
doc/asm.html
to be initialized but the results are assumed uninitialized. If the results will hold live pointers during a call instruction, the function should start by zeroing the results and then executing the pseudo-instruction <code>GO_RESULTS_INITIALIZED</code>. This instruction records that the results are now initialized and should be scanned during stack movement and garbage collection.
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Fri Nov 14 19:09:46 GMT 2025 - 36.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/cache/CacheLoadingTest.java
.isSameInstanceAs(result); } } /** * On a concurrent computation that returns null, all threads should get an * InvalidCacheLoadException, with the loader only called once. The result should not be cached (a * later request should call the loader again). */ private static void testConcurrentLoadingNull(CacheBuilder<Object, Object> builder) throws InterruptedException {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Sep 30 22:03:28 GMT 2025 - 91.1K bytes - Click Count (0)