Search Options

Results per page
Sort
Preferred Languages
Advance

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

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

    1. .readAttributes();
    2. assertThat(attributes.permissions()).containsExactly(OWNER_READ, OWNER_WRITE);
    3. }
    4. }
    5. out.close();
    6.  
    7. // Check that source returns the right data
    8. assertTrue(Arrays.equals(data, source.read()));
    9.  
    10. // Make sure that reset deleted the file
    11. out.reset();
    12. 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

    1. SmbResource n = this.next;
    2. this.next = advance();
    3. return n;
    4. }
    5.  
    6.  
    7. /**
    8. * {@inheritDoc}
    9. *
    10. * @see jcifs.CloseableIterator#close()
    11. */
    12. @Override
    13. public void close () {
    14. // nothing to clean up
    15. this.next = null;
    16. }
    17.  
    18. @Override
    19. public void remove() {
    20. throw new UnsupportedOperationException("remove");
    21. }
    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

    1. ) {
    2. webSocket.send(text)
    3. }
    4.  
    5. override fun onClosing(
    6. webSocket: WebSocket,
    7. code: Int,
    8. reason: String,
    9. ) {
    10. webSocket.close(1000, null)
    11. latch.countDown()
    12. }
    13.  
    14. override fun onFailure(
    15. webSocket: WebSocket,
    16. t: Throwable,
    17. response: Response?,
    18. ) {
    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

    1. responseHeaders = responseHeaders,
    2. outFinished = false,
    3. flushHeaders = false,
    4. )
    5. val out = stream.getSink().buffer()
    6. out.writeUtf8("Not found: $path")
    7. out.close()
    8. }
    9.  
    10. private fun serveDirectory(
    11. stream: Http2Stream,
    12. files: Array<File>,
    13. ) {
    14. val responseHeaders =
    15. listOf(
    16. 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

    1. "fmt"
    2. "net/http"
    3. "strings"
    4. "sync"
    5. )
    6.  
    7. // Target - lambda target interface
    8. type Target interface {
    9. ID() TargetID
    10. IsActive() (bool, error)
    11. Send(Event) (*http.Response, error)
    12. Stat() TargetStat
    13. Close() error
    14. }
    15.  
    16. // TargetStats is a collection of stats for multiple targets.
    17. type TargetStats struct {
    18. TargetStats map[string]TargetStat
    19. }
    20.  
    21. // TargetStat is the stats of a single target.
    22. 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

    1. </h4>
    2. <button type="button" class="close" data-dismiss="modal"
    3. aria-label="Close">
    4. <span aria-hidden="true">×</span>
    5. </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

    1. /**
    2. * Immediately closes the socket connection if it's currently held. Use this to interrupt an
    3. * in-flight request from any thread. It's the caller's responsibility to close the request body
    4. * and response body streams; otherwise resources may be leaked.
    5. *
    6. * 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

    1. if (hasErrors) {
    2. return
    3. }
    4. try {
    5. super.flush()
    6. } catch (e: IOException) {
    7. hasErrors = true
    8. onException(e)
    9. }
    10. }
    11.  
    12. override fun close() {
    13. try {
    14. super.close()
    15. } catch (e: IOException) {
    16. hasErrors = true
    17. onException(e)
    18. }
    19. }
    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

    1. appendFile, err := lock.Open(dst, os.O_WRONLY|os.O_APPEND|os.O_CREATE, 0o666)
    2. if err != nil {
    3. return err
    4. }
    5. defer appendFile.Close()
    6.  
    7. srcFile, err := lock.Open(src, os.O_RDONLY, 0o666)
    8. if err != nil {
    9. return err
    10. }
    11. defer srcFile.Close()
    12. _, err = io.Copy(appendFile, srcFile)
    13. 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

    1. throw new IllegalStateException("More than one source open");
    2. }
    3. return new FilterReader(source.openStream()) {
    4. @Override
    5. public void close() throws IOException {
    6. super.close();
    7. counter[0]--;
    8. }
    9. };
    10. }
    11. };
    12. 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