Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 796 for closely (0.08 sec)

  1. okhttp/src/main/kotlin/okhttp3/ResponseBody.kt

     * must close this body by calling any of the following methods:
     *
     * * `Response.close()`
     * * `Response.body().close()`
     * * `Response.body().source().close()`
     * * `Response.body().charStream().close()`
     * * `Response.body().byteStream().close()`
     * * `Response.body().bytes()`
     * * `Response.body().string()`
     *
     * There is no benefit to invoking multiple `close()` methods for the same response body.
     *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  2. api/maven-api-cli/src/main/java/org/apache/maven/api/cli/mvn/resident/ResidentMavenInvoker.java

    /**
     * Resident invoker. Instance is shut down when this instance is closed.
     *
     * @since 4.0.0
     */
    @Experimental
    public interface ResidentMavenInvoker extends MavenInvoker<MavenInvokerRequest<MavenOptions>> {
        /**
         * Closes cleanly the daemon.
         */
        @Override
        void close() throws InvokerException;
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 04 15:33:25 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt

      `Tut, tut, child!' said the Duchess.  `Everything's got a
    moral, if only you can find it.'  And she squeezed herself up
    closer to Alice's side as she spoke.
    
      Alice did not much like keeping so close to her:  first,
    because the Duchess was VERY ugly; and secondly, because she was
    exactly the right height to rest her chin upon Alice's shoulder,
    and it was an uncomfortably sharp chin.  However, she did not
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 29 21:35:03 UTC 2012
    - 145.2K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

        //     we find them, regardless of what the address policies need.
        //
        //  2. EVICTABLE: Connections not required by any address policy. This matches connections that
        //     don't participate in any policy, plus connections whose policies won't be violated if the
        //     connection is closed. We only close these if the idle connection limit is exceeded.
        //
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  5. internal/s3select/select.go

    		}
    	}
    	return rsc.reader.Read(p)
    }
    
    // Close call to implement io.Closer. Calling Read/Seek after Close reopens the
    // object for reading and a subsequent Close call is required to ensure
    // resources are freed.
    func (rsc *ObjectReadSeekCloser) Close() error {
    	rsc.closerOnce.Do(func() {
    		if rsc.reader != nil {
    			rsc.closerErr = rsc.reader.Close()
    			rsc.reader = nil
    		}
    	})
    	return rsc.closerErr
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt

          if (civilizedFileSystem) return fileSource
    
          lockingSourceCount++
          return object : ForwardingSource(fileSource) {
            private var closed = false
    
            override fun close() {
              super.close()
              if (!closed) {
                closed = true
                synchronized(this@DiskLruCache) {
                  lockingSourceCount--
                  if (lockingSourceCount == 0 && zombie) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  7. internal/s3select/json/reader.go

    	}
    	dstRec.KVS = kvs
    	dstRec.SelectFormat = sql.SelectFmtJSON
    	return dstRec, nil
    }
    
    // Close - closes underlying reader.
    func (r *Reader) Close() error {
    	// Close the input.
    	err := r.readCloser.Close()
    	for range r.valueCh {
    		// Drain values so we don't leak a goroutine.
    		// Since we have closed the input, it should fail rather quickly.
    	}
    	return err
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  8. internal/s3select/simdj/reader.go

    	if !ok {
    		dstRec = &Record{}
    	}
    	dstRec.object = v
    	return dstRec, nil
    }
    
    // Close - closes underlying reader.
    func (r *Reader) Close() error {
    	// Close the input.
    	// Potentially racy if the stream decoder is still reading.
    	if r.readCloser != nil {
    		r.readCloser.Close()
    	}
    	if r.exitReader != nil {
    		close(r.exitReader)
    		r.readerWg.Wait()
    		r.exitReader = nil
    		r.input = nil
    	}
    	return nil
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 30 17:02:22 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  9. internal/http/listener.go

    		if ok {
    			return result.conn, result.err
    		}
    	case <-listener.ctx.Done():
    	}
    	return nil, syscall.EINVAL
    }
    
    // Close - closes underneath all TCP listeners.
    func (listener *httpListener) Close() (err error) {
    	listener.ctxCanceler()
    
    	for i := range listener.listeners {
    		listener.listeners[i].Close()
    	}
    
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  10. internal/event/target/postgresql.go

    	}
    
    	// Delete the event from store.
    	return target.store.Del(key)
    }
    
    // Close - closes underneath connections to PostgreSQL database.
    func (target *PostgreSQLTarget) Close() error {
    	close(target.quitCh)
    	if target.updateStmt != nil {
    		// FIXME: log returned error. ignore time being.
    		_ = target.updateStmt.Close()
    	}
    
    	if target.deleteStmt != nil {
    		// FIXME: log returned error. ignore time being.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.3K bytes
    - Viewed (0)
Back to top