Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 311 - 320 of 1,514 for close (0.07 seconds)

  1. mockwebserver/src/main/kotlin/mockwebserver3/Dispatcher.kt

       * should return immediately. Responses returned after shutdown will not be transmitted: their
       * socket connections have already been closed.
       */
      public open override fun close() {}
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Jun 20 11:46:46 GMT 2025
    - 1.6K bytes
    - Click Count (0)
  2. docs/features/interceptors.md

    Request request = new Request.Builder()
        .url("http://www.publicobject.com/helloworld.txt")
        .header("User-Agent", "OkHttp Example")
        .build();
    
    Response response = client.newCall(request).execute();
    response.body().close();
    ```
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 06 02:19:09 GMT 2022
    - 8.1K bytes
    - Click Count (0)
  3. internal/grid/muxserver.go

    		case <-t.C:
    			last := time.Since(time.Unix(atomic.LoadInt64(&m.LastPing), 0))
    			if last > 4*m.clientPingInterval {
    				gridLogIf(m.ctx, fmt.Errorf("canceling remote connection %s not seen for %v", m.parent, last))
    				m.close()
    				return
    			}
    		}
    	}
    }
    
    // checkSeq will check if sequence number is correct and increment it by 1.
    func (m *muxServer) checkSeq(seq uint32) (ok bool) {
    	if seq != m.RecvSeq {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 9.7K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/io/Flushables.java

       *     method
       * @throws IOException if {@code swallowIOException} is false and {@link Flushable#flush} throws
       *     an {@code IOException}.
       * @see Closeables#close
       */
      @SuppressWarnings("IdentifierName") // See Closeables.close
      public static void flush(Flushable flushable, boolean swallowIOException) throws IOException {
        try {
          flushable.flush();
        } catch (IOException e) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 28 02:48:50 GMT 2024
    - 2.5K bytes
    - Click Count (0)
  5. internal/event/targetlist_test.go

    	return nil
    }
    
    // SendFromStore - interface compatible method does no-op.
    func (target *ExampleTarget) SendFromStore(_ store.Key) error {
    	return nil
    }
    
    func (target ExampleTarget) Close() error {
    	if target.closeErr {
    		return errors.New("close error")
    	}
    
    	return nil
    }
    
    func (target ExampleTarget) IsActive() (bool, error) {
    	return false, errors.New("not connected to target server/service")
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 6K bytes
    - Click Count (0)
  6. src/main/java/jcifs/internal/smb2/rdma/disni/DisniRdmaConnection.java

        }
    
        @Override
        public void close() throws IOException {
            state = RdmaConnectionState.CLOSING;
    
            try {
                // In real implementation, this would close the DiSNI endpoint:
                // if (endpoint != null) {
                //     endpoint.close();
                // }
            } finally {
                state = RdmaConnectionState.CLOSED;
            }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  7. src/test/java/jcifs/internal/smb2/rdma/tcp/TcpRdmaProviderTest.java

            assertFalse(region.hasAccess(RdmaAccess.REMOTE_READ), "Should not have remote read access");
    
            // Test cleanup
            region.close();
            assertFalse(region.isValid(), "Region should be invalid after close");
        }
    
        @Test
        public void testGetProviderName() {
            assertEquals("TCP Fallback", provider.getProviderName());
        }
    
        @Test
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  8. src/main/java/jcifs/smb1/dcerpc/msrpc/SamrAliasHandle.java

            if (rpc.retval != 0) {
                throw new SmbException(rpc.retval, false);
            }
        }
    
        /**
         * Closes this SAM alias handle.
         *
         * @throws IOException if an I/O error occurs during handle closure
         */
        public void close() throws IOException {
            final MsrpcSamrCloseHandle rpc = new MsrpcSamrCloseHandle(this);
            handle.sendrecv(rpc);
            if (rpc.retval != 0) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 2.4K bytes
    - Click Count (0)
  9. build-logic/binary-compatibility/src/main/kotlin/gradlebuild/binarycompatibility/BinaryCompatibilityRepositoryLifecycle.kt

            val userData = context.userData as MutableMap<String, Any?>
            val key = BinaryCompatibilityRepositorySetupRule.REPOSITORY_CONTEXT_KEY
            (userData[key] as BinaryCompatibilityRepository).close()
            userData[key] = null
        }
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Wed Dec 09 08:14:05 GMT 2020
    - 2.2K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/dict/synonym/SynonymFile.java

                    fos = null; // Successfully wrapped, no need to close explicitly
                } catch (final Exception e) {
                    if (fos != null) {
                        try {
                            fos.close();
                        } catch (final IOException ioe) {
                            // Ignore close exception
                        }
                    }
                    if (newFile != null) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 20 07:09:00 GMT 2025
    - 15.9K bytes
    - Click Count (0)
Back to Top