Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 743 for close (0.02 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. okhttp/src/jvmTest/kotlin/okhttp3/ConnectionListenerTest.kt

        server.enqueue(MockResponse())
        server.enqueue(MockResponse())
    
        client
          .newCall(Request(server.url("/")))
          .execute()
          .close()
    
        client
          .newCall(Request(server.url("/")))
          .execute()
          .close()
    
        assertThat(listener.recordedEventTypes()).containsExactly(
          "ConnectStart",
          "ConnectEnd",
          "ConnectionAcquired",
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 18:33:48 GMT 2025
    - 9.7K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/io/MultiInputStream.java

        advance();
      }
    
      @Override
      public void close() throws IOException {
        if (in != null) {
          try {
            in.close();
          } finally {
            in = null;
          }
        }
      }
    
      /** Closes the current input stream and opens the next one, if any. */
      private void advance() throws IOException {
        close();
        if (it.hasNext()) {
          in = it.next().openStream();
        }
      }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed May 14 19:40:47 GMT 2025
    - 2.8K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

     *
     * {@snippet :
     * FluentFuture<UserName> userName =
     *     ClosingFuture.submit(
     *             closer -> closer.eventuallyClose(database.newTransaction(), closingExecutor),
     *             executor)
     *         .transformAsync((closer, transaction) -> transaction.queryClosingFuture("..."), executor)
     *         .transform((closer, result) -> result.get("userName"), directExecutor())
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Sep 11 13:51:27 GMT 2025
    - 96.9K bytes
    - Click Count (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/MessageInflater.kt

        if (inflater.bytesRead < totalBytesToRead) {
          deflatedBytes.clear()
          inflaterSource.close()
          this.inflaterSource = null
          this.inflater = null
        }
      }
    
      @Throws(IOException::class)
      override fun close() {
        inflaterSource?.close()
        inflaterSource = null
        inflater = null
      }
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sun Sep 21 06:26:07 GMT 2025
    - 2.4K bytes
    - Click Count (0)
  6. src/archive/zip/writer.go

    	w.comment = comment
    	return nil
    }
    
    // Close finishes writing the zip file by writing the central directory.
    // It does not close the underlying writer.
    func (w *Writer) Close() error {
    	if w.last != nil && !w.last.closed {
    		if err := w.last.close(); err != nil {
    			return err
    		}
    		w.last = nil
    	}
    	if w.closed {
    		return errors.New("zip: writer closed twice")
    	}
    	w.closed = true
    
    	// write central directory
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Jan 28 04:20:09 GMT 2025
    - 19.4K bytes
    - Click Count (0)
  7. internal/lock/lock_test.go

    	}
    
    	// Decrease reference count by 1.
    	if err = rlk.Close(); err != nil {
    		t.Fatal(err)
    	}
    
    	isClosed = rlk.IsClosed()
    	if isClosed {
    		t.Fatal("File ref count shouldn't be zero")
    	}
    
    	// Decrease reference count by 1.
    	if err = rlk.Close(); err != nil {
    		t.Fatal(err)
    	}
    
    	// Now file should be closed.
    	isClosed = rlk.IsClosed()
    	if !isClosed {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 3.7K bytes
    - Click Count (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/FastFallbackTest.kt

        url =
          serverIpv4
            .url("/")
            .newBuilder()
            .host("localhost")
            .build()
      }
    
      @AfterEach
      internal fun tearDown() {
        serverIpv4.close()
        serverIpv6.close()
      }
    
      @Test
      fun callIpv6FirstEvenWhenIpv4IpIsListedFirst() {
        dnsResults =
          listOf(
            localhostIpv4,
            localhostIpv6,
          )
        serverIpv4.enqueue(
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 10.6K bytes
    - Click Count (0)
  9. src/archive/zip/example_test.go

    		if err != nil {
    			log.Fatal(err)
    		}
    	}
    
    	// Make sure to check the error on Close.
    	err := w.Close()
    	if err != nil {
    		log.Fatal(err)
    	}
    }
    
    func ExampleReader() {
    	// Open a zip archive for reading.
    	r, err := zip.OpenReader("testdata/readme.zip")
    	if err != nil {
    		log.Fatal(err)
    	}
    	defer r.Close()
    
    	// Iterate through the files in the archive,
    	// printing some of their contents.
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Wed Jan 27 00:22:03 GMT 2016
    - 2K bytes
    - Click Count (0)
  10. .github/workflows/invalid_question.yml

    name: "Close invalid questions issues"
    on:
      schedule:
      - cron: "*/10 * * * *"
    
    permissions:
      contents: read
    
    jobs:
      stale:
        permissions:
          issues: write  # for actions/stale to close stale issues
          pull-requests: write  # for actions/stale to close stale PRs
        runs-on: ubuntu-latest
        env:
          ACTIONS_STEP_DEBUG: true
        steps:
        - name: Close Stale Issues
          uses: actions/stale@v8
          with:
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Tue Apr 11 02:27:05 GMT 2023
    - 1.2K bytes
    - Click Count (0)
Back to Top