Search Options

Results per page
Sort
Preferred Languages
Advance

Results 321 - 330 of 887 for closure (0.15 sec)

  1. cmd/metrics-v2.go

    		for _, mf := range mfs {
    			if err := enc.Encode(mf); err != nil {
    				// client may disconnect for any reasons
    				// we do not have to log this.
    				return
    			}
    		}
    		if closer, ok := enc.(expfmt.Closer); ok {
    			closer.Close()
    		}
    	})
    }
    
    func metricsBucketHandler() http.Handler {
    	return metricsHTTPHandler(bucketCollector, "handler.MetricsBucket")
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
  2. src/test/java/jcifs/tests/FileAttributesTest.java

                try {
                    assertTrue(checkFile.exists());
                }
                finally {
                    ostream.close();
                    checkFile.close();
                    f.delete();
                }
            }
        }
    
    
        /**
         * @author Ilan Goldfeld
         */
        // #261
        @Test
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Thu Jan 05 13:09:03 UTC 2023
    - 12.3K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

        assertThat(response2.body.source().readUtf8(3)).isEqualTo("JKL")
        assertThat(server.takeRequest().sequenceNumber).isEqualTo(0)
        assertThat(server.takeRequest().sequenceNumber).isEqualTo(1)
        response1.close()
        response2.close()
      }
    
      @ParameterizedTest
      @ArgumentsSource(ProtocolParamProvider::class)
      fun connectionWindowUpdateAfterCanceling(
        protocol: Protocol,
        mockWebServer: MockWebServer,
      ) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 75.3K bytes
    - Viewed (0)
  4. tests/test_tutorial/test_websockets/test_tutorial003_py39.py

            client1_says = "Client #1234 says: Hello from 1234"
            assert data2 == client1_says
            data1 = connection.receive_text()
            assert data1 == client1_says
            connection_two.close()
            data1 = connection.receive_text()
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Mar 18 12:29:59 UTC 2023
    - 1.3K bytes
    - Viewed (0)
  5. build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/AcceptedApiChangesJsonFileManager.groovy

            jsonFile.withWriter { fileWriter ->
                def writer = new JsonWriter(fileWriter)
                writer.setIndent("    ")
                new Gson().toJson([acceptedApiChanges: []], Object, writer)
                writer.close()
            }
        }
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Dec 09 08:14:05 UTC 2020
    - 1K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/URLConnectionTest.kt

        server.enqueue(response)
        val request = newRequest("/")
        val c1 = getResponse(request)
        assertContent("ABCDE", c1, 5)
        val c2 = getResponse(request)
        assertContent("ABCDE", c2, 5)
        c1.close()
        c2.close()
      }
    
      @Test
      fun connectionsArePooled() {
        val response =
          MockResponse(
            body = "ABCDEFGHIJKLMNOPQR",
          )
        server.enqueue(response)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 131.7K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/core/io/SerializeUtil.java

                final ObjectOutputStream oos = new ObjectOutputStream(baos);
                try {
                    oos.writeObject(obj);
                } finally {
                    oos.close();
                }
                return baos.toByteArray();
            } catch (final IOException ex) {
                throw new IORuntimeException(ex);
            }
        }
    
        /**
         * {@literal byte}の配列をオブジェクトに変換します。
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/io/MultiInputStreamTest.java

                  throw new IllegalStateException("More than one source open");
                }
                return new FilterInputStream(source.openStream()) {
                  @Override
                  public void close() throws IOException {
                    super.close();
                    counter[0]--;
                  }
                };
              }
            };
        byte[] result = ByteSource.concat(checker, checker, checker).read();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 4.6K bytes
    - Viewed (0)
  9. okcurl/src/main/kotlin/okhttp3/curl/internal/-MainCommon.kt

        val source = response.body.source()
        while (!source.exhausted()) {
          out.write(source.buffer, source.buffer.size)
          out.flush()
        }
    
        response.body.close()
      } catch (e: IOException) {
        e.printStackTrace()
      } finally {
        close()
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  10. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainServerSocketFactory.java

            SocketException exception = new SocketException();
            exception.initCause(e);
            throw exception;
          }
        }
    
        @Override public void close() throws IOException {
          serverSocketChannel.close();
        }
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Feb 12 16:33:52 UTC 2019
    - 3.1K bytes
    - Viewed (0)
Back to top