Search Options

Results per page
Sort
Preferred Languages
Advance

Results 261 - 270 of 579 for OPEN (0.03 sec)

  1. build-logic/binary-compatibility/src/main/kotlin/gradlebuild/binarycompatibility/BinaryCompatibilityRepository.kt

    import japicmp.model.JApiMethod
    import javassist.bytecode.SourceFileAttribute
    import java.io.File
    
    
    /**
     * Repository of sources for binary compatibility checks.
     *
     * `WARN` Holds resources open for performance, must be closed after use.
     */
    class BinaryCompatibilityRepository internal constructor(
    
        private
        val sources: SourcesRepository
    
    ) : AutoCloseable {
    
        companion object {
    
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Fri Jun 28 08:29:28 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/cache/FaultHidingSink.kt

    package okhttp3.internal.cache
    
    import java.io.IOException
    import okio.Buffer
    import okio.ForwardingSink
    import okio.Sink
    
    /** A sink that never throws IOExceptions, even if the underlying sink does. */
    internal open class FaultHidingSink(
      delegate: Sink,
      val onException: (IOException) -> Unit,
    ) : ForwardingSink(delegate) {
      private var hasErrors = false
    
      override fun write(
        source: Buffer,
        byteCount: Long,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/http1/HeadersReader.kt

    /*
     * Copyright (C) 2012 The Android Open Source Project
     *
     * Licensed under the Apache License, Version 2.0 (the "License");
     * you may not use this file except in compliance with the License.
     * You may obtain a copy of the License at
     *
     *      http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Dec 20 23:27:07 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  4. fastapi/background.py

        ## Example
    
        ```python
        from fastapi import BackgroundTasks, FastAPI
    
        app = FastAPI()
    
    
        def write_notification(email: str, message=""):
            with open("log.txt", mode="w") as email_file:
                content = f"notification for {email}: {message}"
                email_file.write(content)
    
    
        @app.post("/send-notification/{email}")
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Apr 02 02:48:51 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/io/ByteSourceTest.java

       * source, and finally additional bytes are appended to the source before the stream is read.
       *
       * <p>Without special handling, it's possible to have reads of the open stream start <i>before</i>
       * the offset at which the slice is supposed to start.
       */
      // TODO(cgdecker): Maybe add a test for this to ByteSourceTester
      public void testSlice_appendingAfterSlicing() throws IOException {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  6. internal/event/target/postgresql.go

    }
    
    func (target *PostgreSQLTarget) init() error {
    	return target.initOnce.Do(target.initPostgreSQL)
    }
    
    func (target *PostgreSQLTarget) initPostgreSQL() error {
    	args := target.args
    
    	db, err := sql.Open("postgres", target.connString)
    	if err != nil {
    		return err
    	}
    	target.db = db
    
    	if args.MaxOpenConnections > 0 {
    		// Set the maximum connections limit
    		target.db.SetMaxOpenConns(args.MaxOpenConnections)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/io/MultiReaderTest.java

            new CharSource() {
              @Override
              public Reader openStream() throws IOException {
                if (counter[0]++ != 0) {
                  throw new IllegalStateException("More than one source open");
                }
                return new FilterReader(source.openStream()) {
                  @Override
                  public void close() throws IOException {
                    super.close();
                    counter[0]--;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 3.7K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/io/MultiReaderTest.java

            new CharSource() {
              @Override
              public Reader openStream() throws IOException {
                if (counter[0]++ != 0) {
                  throw new IllegalStateException("More than one source open");
                }
                return new FilterReader(source.openStream()) {
                  @Override
                  public void close() throws IOException {
                    super.close();
                    counter[0]--;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 3.7K bytes
    - Viewed (0)
  9. internal/lock/lock.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    // Package lock - implements filesystem locking wrappers around an
    // open file descriptor.
    package lock
    
    import (
    	"errors"
    	"os"
    	"sync"
    )
    
    // ErrAlreadyLocked is returned if the underlying fd is already locked.
    var ErrAlreadyLocked = errors.New("file already locked")
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  10. doc/README.md

    To preview `next` content in merged form using a local instance of the website, run:
    
    ```
    go run golang.org/x/website/cmd/golangorg@latest -goroot=..
    ```
    
    Then open http://localhost:6060/doc/next. Refresh the page to see your latest edits.
    
    ## For the release team
    
    The `relnote` tool, at `golang.org/x/build/cmd/relnote`, operates on the files
    in `doc/next`.
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Jul 22 17:55:04 UTC 2024
    - 3.1K bytes
    - Viewed (0)
Back to top