Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 1,032 for _close (0.05 seconds)

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

  1. android/guava/src/com/google/common/io/Closeables.java

       *     // If an exception occurs, rethrow it only if threw==false:
       *     Closeables.close(stream, threw);
       *   }
       * }
       * }
       *
       * @param closeable the {@code Closeable} object to be closed, or null, in which case this method
       *     does nothing
       * @param swallowIOException if true, don't propagate IO exceptions thrown by the {@code close}
       *     methods
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 5.1K bytes
    - Click Count (0)
  2. 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
    }
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 30 17:02:22 GMT 2023
    - 4.9K bytes
    - Click Count (0)
  3. cmd/metacache-stream.go

    				continue
    			}
    		}
    	}()
    
    	return objs, nil
    }
    
    // Close and release resources.
    func (w *metacacheWriter) Close() error {
    	if w == nil || w.closer == nil {
    		return nil
    	}
    	w.streamWg.Wait()
    	err := w.closer()
    	w.closer = nil
    	return err
    }
    
    // Reset and start writing to new writer.
    // Close must have been called before this.
    func (w *metacacheWriter) Reset(out io.Writer) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed May 07 15:37:12 GMT 2025
    - 19.5K bytes
    - Click Count (0)
  4. src/test/java/jcifs/smb/SmbWatchHandleImplTest.java

        }
    
        // close() should close underlying handle with 0L when valid
        @Test
        @DisplayName("close() closes underlying handle when valid")
        void close_validHandle_invokesClose() throws Exception {
            when(handle.isValid()).thenReturn(true);
            SmbWatchHandleImpl sut = new SmbWatchHandleImpl(handle, 0, false);
    
            sut.close();
    
            verify(handle, times(1)).close(0L);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 11.5K bytes
    - Click Count (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

        ) {
          check(!closed) { "closed" }
          checkOffsetAndCount(source.size, 0, byteCount)
          socket.sink.write(source, byteCount)
        }
    
        override fun flush() {
          if (closed) return // Don't throw; this stream might have been closed on the caller's behalf.
          socket.sink.flush()
        }
    
        override fun close() {
          if (closed) return
          closed = true
          detachTimeout(timeout)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 17.6K bytes
    - Click Count (7)
  6. okhttp/src/commonJvmAndroid/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.
     *
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue May 27 14:51:25 GMT 2025
    - 11.6K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

      // Avoid infinite recursion if a closeable's close() method throws RejectedExecutionException and
      // is closed using the direct executor.
      public void testCloseThrowsRejectedExecutionException() throws Exception {
        doThrow(new RejectedExecutionException()).when(mockCloseable).close();
        ClosingFuture<Closeable> closingFuture =
            ClosingFuture.submit(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 63K bytes
    - Click Count (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt

      override fun clone(): Call = RealCall(client, originalRequest, forWebSocket)
    
      override fun request(): Request = originalRequest
    
      /**
       * 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
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Jan 11 12:06:21 GMT 2026
    - 19.5K bytes
    - Click Count (0)
  9. src/test/java/jcifs/smb/DirFileEntryEnumIterator1Test.java

            // Close should have sent FindClose2 exactly once
            ArgumentCaptor<SmbComFindClose2> captor = ArgumentCaptor.forClass(SmbComFindClose2.class);
            verify(tree, times(1)).send(captor.capture(), any());
            assertNotNull(captor.getValue());
    
            // Tree handle is released after close
            verify(tree, atLeastOnce()).release();
        }
    
        @Test
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 12.7K bytes
    - Click Count (0)
  10. src/test/java/jcifs/smb/SmbFileHandleImplTest.java

            h.close(777L);
    
            // Verify SMB2 close path
            verify(tree, times(1)).send(isA(Smb2CloseRequest.class), eq(RequestParam.NO_RETRY));
            // Tree is always released in finally
            verify(tree, times(1)).release();
        }
    
        @Test
        @DisplayName("close(long) sends SMB1 close request and releases tree when SMB1")
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 12.3K bytes
    - Click Count (0)
Back to Top