Search Options

Results per page
Sort
Preferred Languages
Advance

Results 261 - 270 of 887 for closure (0.14 sec)

  1. guava-tests/test/com/google/common/io/FileBackedOutputStreamTest.java

                    .readAttributes();
            assertThat(attributes.permissions()).containsExactly(OWNER_READ, OWNER_WRITE);
          }
        }
        out.close();
    
        // Check that source returns the right data
        assertTrue(Arrays.equals(data, source.read()));
    
        // Make sure that reset deleted the file
        out.reset();
        if (file != null) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb/ShareEnumIterator.java

            SmbResource n = this.next;
            this.next = advance();
            return n;
        }
    
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.CloseableIterator#close()
         */
        @Override
        public void close () {
            // nothing to clean up
            this.next = null;
        }
    
        @Override
        public void remove() {
            throw new UnsupportedOperationException("remove");
        }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 3.5K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/AutobahnTester.kt

            ) {
              webSocket.send(text)
            }
    
            override fun onClosing(
              webSocket: WebSocket,
              code: Int,
              reason: String,
            ) {
              webSocket.close(1000, null)
              latch.countDown()
            }
    
            override fun onFailure(
              webSocket: WebSocket,
              t: Throwable,
              response: Response?,
            ) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  4. mockwebserver/src/test/java/mockwebserver3/internal/http2/Http2Server.kt

          responseHeaders = responseHeaders,
          outFinished = false,
          flushHeaders = false,
        )
        val out = stream.getSink().buffer()
        out.writeUtf8("Not found: $path")
        out.close()
      }
    
      private fun serveDirectory(
        stream: Http2Stream,
        files: Array<File>,
      ) {
        val responseHeaders =
          listOf(
            Header(":status", "200"),
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  5. internal/config/lambda/event/targetlist.go

    	"fmt"
    	"net/http"
    	"strings"
    	"sync"
    )
    
    // Target - lambda target interface
    type Target interface {
    	ID() TargetID
    	IsActive() (bool, error)
    	Send(Event) (*http.Response, error)
    	Stat() TargetStat
    	Close() error
    }
    
    // TargetStats is a collection of stats for multiple targets.
    type TargetStats struct {
    	TargetStats map[string]TargetStat
    }
    
    // TargetStat is the stats of a single target.
    type TargetStat struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  6. src/main/webapp/WEB-INF/view/admin/role/admin_role_details.jsp

                                                        </h4>
                                                        <button type="button" class="close" data-dismiss="modal"
                                                                aria-label="Close">
                                                            <span aria-hidden="true">×</span>
                                                        </button>
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 13 07:47:04 UTC 2020
    - 6.9K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

      /**
       * Immediately closes the socket connection if it's currently held. Use this to interrupt an
       * in-flight request from any thread. It's the caller's responsibility to close the request body
       * and response body streams; otherwise resources may be leaked.
       *
       * This method is safe to be called concurrently, but provides limited guarantees. If a transport
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/cache/FaultHidingSink.kt

        if (hasErrors) {
          return
        }
        try {
          super.flush()
        } catch (e: IOException) {
          hasErrors = true
          onException(e)
        }
      }
    
      override fun close() {
        try {
          super.close()
        } catch (e: IOException) {
          hasErrors = true
          onException(e)
        }
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  9. internal/ioutil/append-file_windows.go

    	appendFile, err := lock.Open(dst, os.O_WRONLY|os.O_APPEND|os.O_CREATE, 0o666)
    	if err != nil {
    		return err
    	}
    	defer appendFile.Close()
    
    	srcFile, err := lock.Open(src, os.O_RDONLY, 0o666)
    	if err != nil {
    		return err
    	}
    	defer srcFile.Close()
    	_, err = io.Copy(appendFile, srcFile)
    	return err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 1.2K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/io/MultiReaderTest.java

                  throw new IllegalStateException("More than one source open");
                }
                return new FilterReader(source.openStream()) {
                  @Override
                  public void close() throws IOException {
                    super.close();
                    counter[0]--;
                  }
                };
              }
            };
        Reader joinedReader = CharSource.concat(reader, reader, reader).openStream();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 3.7K bytes
    - Viewed (0)
Back to top