Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 869 for Closer (0.04 seconds)

  1. android/guava/src/com/google/common/collect/Range.java

       * returned range is {@linkplain BoundType#CLOSED closed} on both ends.
       *
       * @since 14.0
       */
      public static <C extends Comparable<?>> Range<C> singleton(C value) {
        return closed(value, value);
      }
    
      /**
       * Returns the minimal range that {@linkplain Range#contains(Comparable) contains} all of the
       * given values. The returned range is {@linkplain BoundType#CLOSED closed} on both ends.
       *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 18:35:44 GMT 2025
    - 28K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/collect/ContiguousSet.java

       * (inclusive) to {@code upper} (inclusive). (These are the same values contained in {@code
       * Range.closed(lower, upper)}.)
       *
       * @throws IllegalArgumentException if {@code lower} is greater than {@code upper}
       * @since 23.0
       */
      public static ContiguousSet<Integer> closed(int lower, int upper) {
        return create(Range.closed(lower, upper), DiscreteDomain.integers());
      }
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 9.9K bytes
    - Click Count (0)
  3. .github/workflows/stale-issues.yml

                It will be closed if no further activity occurs. Thank you.
              close-issue-message: >
                This issue was closed because it has been inactive for 7 days since being marked as stale.
                Please reopen if you'd like to work on this further.
              days-before-pr-stale: 14
              days-before-pr-close: 14
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Sat Nov 01 08:08:54 GMT 2025
    - 4.1K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/MultipartReader.kt

            else -> throw EOFException() // We ran out of data before we found the required boundary.
          }
        }
    
        @Throws(IOException::class)
        override fun close() {
          if (closed) return
          closed = true
          currentPart = null
          source.close()
        }
    
        /** A single part in a multipart body. */
        class Part(
          @get:JvmName("headers") val headers: Headers,
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed May 28 02:11:14 GMT 2025
    - 7.3K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/ResponseBodyTest.kt

              val source = Buffer().writeUtf8("hello")
              return object : ForwardingSource(source) {
                override fun close() {
                  closed = true
                  super.close()
                }
              }.buffer()
            }
          }
        body.source().close()
        assertThat(closed).isTrue()
      }
    
      @Test
      fun throwingUnderlyingSourceClosesQuietly() {
        val body: ResponseBody =
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 3.9K bytes
    - Click Count (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/TrailersTest.kt

            measureTime {
              val exception =
                assertFailsWith<IOException> {
                  response.trailers()
                }
              assertThat(exception.message).isIn(
                "Socket closed", // HTTP/1.1
                "stream was reset: CANCEL", // HTTP/2
              )
            }
          assertThat(trailersDelay).isGreaterThan(250.milliseconds)
          assertThat(trailersDelay).isLessThan(750.milliseconds)
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Nov 08 21:45:04 GMT 2025
    - 18.8K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilJvm.kt

        this.isNullOrEmpty() -> emptyList()
        this.size == 1 -> Collections.singletonList(this[0])
        else -> this.clone().asList().unmodifiable()
      }
    
    /** Closes this, ignoring any checked exceptions. */
    internal fun Socket.closeQuietly() {
      try {
        close()
      } catch (e: AssertionError) {
        throw e
      } catch (rethrown: RuntimeException) {
        if (rethrown.message == "bio == null") {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 10.2K bytes
    - Click Count (1)
  8. okhttp/src/jvmTest/kotlin/okhttp3/ResponseBodyJvmTest.kt

                @Throws(IOException::class)
                override fun close() {
                  closed.set(true)
                  super.close()
                }
              }.buffer()
            }
          }
        body.charStream().close()
        assertThat(closed.get()).isTrue()
      }
    
      @Test
      fun readerClosedAfterBomClosesUnderlyingSource() {
        val closed = AtomicBoolean()
        val body: ResponseBody =
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 12.4K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/io/AppendableWriter.java

        checkNotClosed();
        if (target instanceof Flushable) {
          ((Flushable) target).flush();
        }
      }
    
      @Override
      public void close() throws IOException {
        this.closed = true;
        if (target instanceof Closeable) {
          ((Closeable) target).close();
        }
      }
    
      @Override
      public Writer append(char c) throws IOException {
        checkNotClosed();
        target.append(c);
        return this;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:37:28 GMT 2025
    - 3.4K bytes
    - Click Count (0)
  10. build-logic/kotlin-dsl-shared-runtime/src/main/kotlin/org/gradle/kotlin/dsl/internal/sharedruntime/codegen/ApiTypeProvider.kt

                    apiTypeFor(sourceName, classBytes)
                }!!
            }.map { it() }
        }
    
        override fun close() =
            try {
                repository.close()
            } finally {
                closed = true
            }
    
        private
        fun apiTypeFor(sourceName: String, classBytes: () -> ByteArray): () -> ApiType = {
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Wed Mar 12 15:56:18 GMT 2025
    - 20.2K bytes
    - Click Count (0)
Back to Top