Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 1,049 for closes (0.1 sec)

  1. src/test/java/jcifs/util/SmbCircuitBreakerTest.java

            // Need successThreshold (2) consecutive successes to close the circuit
            // Second success should close the circuit (threshold is 2)
            result = circuitBreaker.executeWithCircuitBreaker(() -> "success 1");
            assertEquals("success 1", result, "Should execute second success");
            assertEquals(State.CLOSED, circuitBreaker.getState(), "Circuit should be CLOSED after success threshold");
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 23.2K bytes
    - Viewed (0)
  2. src/main/java/jcifs/util/ResourceManager.java

            public T get() {
                if (closed) {
                    throw new IllegalStateException("Resource has been closed: " + resourceId);
                }
                return resource;
            }
    
            @Override
            public void close() throws Exception {
                if (closed) {
                    return;
                }
    
                try {
                    resource.close();
                } finally {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 16.2K bytes
    - Viewed (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
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Sat Feb 01 08:42:17 UTC 2025
    - 4.1K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/ResponseBodyTest.kt

                override fun close() {
                  closed = true
                  super.close()
                }
              }.buffer()
            }
          }
        body.source().close()
        assertThat(closed).isTrue()
      }
    
      @Test
      fun throwingUnderlyingSourceClosesQuietly() {
        val body: ResponseBody =
          object : ResponseBody() {
            override fun contentType(): MediaType? = null
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 3.9K bytes
    - Viewed (0)
  5. 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 =
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 12.4K bytes
    - Viewed (0)
  6. 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;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:37:28 UTC 2025
    - 3.4K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/MultipartReader.kt

          }
        }
    
        @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,
          @get:JvmName("body") val body: BufferedSource,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 02:11:14 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/core/io/CopyUtil.java

            } finally {
                CloseableUtil.close(os);
            }
        }
    
        // ////////////////////////////////////////////////////////////////
        // from InputStream to StringBuilder
        //
        /**
         * Copies from an input stream to a {@link StringBuilder} using the platform default encoding.
         * <p>
         * The input stream is not closed.
         * </p>
         *
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Thu Jul 31 08:16:49 UTC 2025
    - 45.2K bytes
    - Viewed (0)
  9. CHANGELOG/CHANGELOG-1.8.md

      Don't use these flags. Using deprecated flags causes the server to print a warning. Using a removed flag causes the server to abort the startup.
    
    * The following deprecated flags were removed from `kubelet`:
    
      * `api-servers` - add apiserver addresses to the kubeconfig file instead.
    
      Don't use these flags. Using deprecated flags causes the kubelet to print a warning. Using a removed flag causes the kubelet to abort the startup.
    
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Tue Feb 20 15:45:02 UTC 2024
    - 312.2K bytes
    - Viewed (0)
  10. src/test/java/jcifs/smb/SmbPipeInputStreamTest.java

            }).when(tree).send(any(TransPeekNamedPipe.class), any(TransPeekNamedPipeResponse.class), eq(RequestParam.NO_RETRY));
    
            int available = stream.available();
            assertEquals(0, available, "Disconnected/server-closed should yield 0 available");
    
            verify(fd, times(1)).markClosed();
            verify(tree, times(1)).close();
            verify(fd, times(1)).close();
        }
    
        @Test
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 9.9K bytes
    - Viewed (0)
Back to top