Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 411 - 420 of 1,033 for Close (0.02 seconds)

  1. doc/README.md

    unfinished release note work.
    
    To prepare the release notes for a release, run `relnote generate`.
    That will merge the `.md` files in `next` into a single file.
    Atomically (as close to it as possible) add that file to `_content/doc` directory
    of the website repository and remove the `doc/next` directory in this repository.
    
    To begin the next release development cycle, populate the contents of `next`
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Jul 22 17:55:04 GMT 2024
    - 3.1K bytes
    - Click Count (0)
  2. mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt

      @Test
      fun closeWithoutStart() {
        val server = MockWebServer()
        server.close()
      }
    
      @Test
      fun closeViaClosable() {
        val server: Closeable = MockWebServer()
        server.close()
      }
    
      @Test
      fun closeWithoutEnqueue() {
        val server = MockWebServer()
        server.start()
        server.close()
      }
    
      @Test
      fun portValidAfterStart() {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Aug 03 22:38:00 GMT 2025
    - 28K bytes
    - Click Count (0)
  3. src/main/java/jcifs/context/CIFSContextWrapper.java

        }
    
        @Override
        public SmbTransportPool getTransportPool() {
            return this.delegate.getTransportPool();
        }
    
        @Override
        public boolean close() throws CIFSException {
            return this.delegate.close();
        }
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 4.9K bytes
    - Click Count (0)
  4. api/maven-api-cli/src/main/java/org/apache/maven/api/cli/Invoker.java

         * if they need to perform cleanup operations.</p>
         *
         * @throws InvokerException if an error occurs while closing the {@link Invoker}
         */
        @Override
        default void close() throws InvokerException {}
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jan 31 20:56:58 GMT 2025
    - 2.6K bytes
    - Click Count (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilJvm.kt

        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 Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 10.3K bytes
    - Click Count (1)
  6. internal/ringbuffer/ring_buffer.go

    func (r *RingBuffer) WriteCloser() io.WriteCloser {
    	return &writeCloser{RingBuffer: r}
    }
    
    type writeCloser struct {
    	*RingBuffer
    }
    
    // Close provides a close method for the WriteCloser.
    func (wc *writeCloser) Close() error {
    	wc.CloseWriter()
    	return wc.Flush()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 13.3K bytes
    - Click Count (0)
  7. src/main/java/jcifs/util/SimpleCircuitBreaker.java

         *
         * @param name the circuit breaker name
         * @param failureThreshold number of consecutive failures to open circuit
         * @param successThreshold number of successes in half-open to close circuit
         * @param timeoutMillis timeout before attempting to close open circuit
         */
        public SimpleCircuitBreaker(String name, int failureThreshold, int successThreshold, long timeoutMillis) {
            this.name = name;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 11.3K bytes
    - Click Count (0)
  8. internal/s3select/jstream/scanner.go

    		fillReq:   make(chan struct{}),
    		fillReady: make(chan int64),
    	}
    
    	go func() {
    		var rpos int64 // total bytes read into buffer
    
    		defer func() {
    			atomic.StoreInt64(&sr.end, rpos)
    			close(sr.fillReady)
    		}()
    
    		for range sr.fillReq {
    		scan:
    			n, err := r.Read(sr.nbuf[:])
    
    			if n == 0 {
    				switch err {
    				case io.EOF: // reader is exhausted
    					return
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Sep 23 19:35:41 GMT 2024
    - 2.5K bytes
    - Click Count (0)
  9. okhttp-dnsoverhttps/src/test/java/okhttp3/dnsoverhttps/TestDohMain.kt

            getOnly = true,
          )
        runBatch(dnsProviders, names)
      } finally {
        bootstrapClient.connectionPool.evictAll()
        bootstrapClient.dispatcher.executorService.shutdownNow()
        bootstrapClient.cache?.close()
      }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/ResponseCommonTest.kt

       */
      private fun responseBody(content: String): ResponseBody {
        val data = Buffer().writeUtf8(content)
        val source: Source =
          object : Source {
            var closed = false
    
            override fun close() {
              closed = true
            }
    
            override fun read(
              sink: Buffer,
              byteCount: Long,
            ): Long {
              check(!closed)
              return data.read(sink, byteCount)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 3.6K bytes
    - Click Count (0)
Back to Top