Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 331 - 340 of 817 for closer (0.04 seconds)

  1. compat/maven-model-builder/src/main/java/org/apache/maven/model/io/ModelWriter.java

         */
        void write(File output, Map<String, Object> options, Model model) throws IOException;
    
        /**
         * Writes the supplied model to the specified character writer. The writer will be automatically closed before the
         * method returns.
         *
         * @param output The writer to serialize the model to, must not be {@code null}.
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Tue Feb 25 08:27:34 GMT 2025
    - 2.9K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/MessageDeflater.kt

          deflatedBytes.writeByte(0x00)
        }
    
        buffer.write(deflatedBytes, deflatedBytes.size)
      }
    
      @Throws(IOException::class)
      override fun close() = deflaterSink.close()
    
      private fun Buffer.endsWith(suffix: ByteString): Boolean = rangeEquals(size - suffix.size, suffix)
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 2.1K bytes
    - Click Count (0)
  3. 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();
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 3.7K bytes
    - Click Count (0)
  4. tests/test_validation_error_context.py

        await websocket.send_text(f"Item: {item_id}")  # pragma: no cover
        await websocket.close()  # pragma: no cover
    
    
    @sub_app.websocket("/ws/{item_id}")
    async def subapp_websocket_endpoint(websocket: WebSocket, item_id: int):
        await websocket.accept()  # pragma: no cover
        await websocket.send_text(f"Item: {item_id}")  # pragma: no cover
        await websocket.close()  # pragma: no cover
    
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Dec 06 12:21:57 GMT 2025
    - 4.7K bytes
    - Click Count (0)
  5. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainSocketFactory.java

        Socket result = createSocket();
    
        try {
          result.connect(new InetSocketAddress(host, port));
        } catch (IOException e) {
          result.close();
          throw e;
        }
        return result;
      }
    
      @Override public Socket createSocket(
          String host, int port, InetAddress localHost, int localPort) throws IOException {
        return createSocket(host, port);
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sun Dec 03 21:33:52 GMT 2023
    - 2.1K bytes
    - Click Count (0)
  6. internal/ioutil/wait_pipe.go

    	done func()
    }
    
    // CloseWithError close with supplied error the writer end.
    func (w *PipeWriter) CloseWithError(err error) error {
    	err = w.PipeWriter.CloseWithError(err)
    	w.once.Do(func() {
    		w.done()
    	})
    	return err
    }
    
    // PipeReader is similar to io.PipeReader with wait group
    type PipeReader struct {
    	*io.PipeReader
    	wait func()
    }
    
    // CloseWithError close with supplied error the reader end
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Apr 27 14:55:36 GMT 2023
    - 1.7K bytes
    - Click Count (0)
  7. build-logic/documentation/src/test/resources/org/gradle/test/GroovyClassWithImports.groovy

    package org.gradle.test
    
    import org.gradle.test.sub.*;
    
    class GroovyClassWithImports extends SubGroovyClass implements SubJavaInterface, GroovyInterface {
        void close() {
        }
    }
    
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Wed Dec 09 08:14:05 GMT 2020
    - 228 bytes
    - Click Count (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

        assertThat(c0e0.exchangeIndex).isEqualTo(0)
        val c0e1 = server.takeRequest()
        assertThat(c0e1.connectionIndex).isEqualTo(0)
        assertThat(c0e1.exchangeIndex).isEqualTo(1)
        response1.close()
        response2.close()
      }
    
      @Test
      fun connectionWindowUpdateAfterCanceling() {
        server.enqueue(
          MockResponse
            .Builder()
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Nov 01 12:18:11 GMT 2025
    - 67.4K bytes
    - Click Count (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/RetryConnectionTest.kt

      @RegisterExtension
      val clientTestRule = OkHttpClientTestRule()
    
      private var client = clientTestRule.newClient()
    
      @AfterEach internal fun tearDown() {
        factory.close()
      }
    
      @Test fun nonRetryableIOException() {
        val exception = IOException("Non-handshake exception")
        assertThat(retryTlsHandshake(exception)).isFalse()
      }
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  10. android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt

              }
            }
            assertEquals(TlsVersion.TLS_1_3, response.handshake?.tlsVersion)
          }
        } finally {
          Security.removeProvider("Conscrypt")
          client.close()
        }
      }
    
      @Test
      fun testConscryptRequestLocalhostInsecure() {
        try {
          Security.insertProviderAt(Conscrypt.newProviderBuilder().build(), 1)
    
          val clientCertificates =
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 29.9K bytes
    - Click Count (0)
Back to Top