- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 77 for writeNL (0.5 sec)
-
okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt
return object : RequestBody() { override fun contentType(): MediaType? { return "text/plain".toMediaTypeOrNull() } @Throws(IOException::class) override fun writeTo(sink: BufferedSink) { try { sink.writeUtf8("abc") sink.flush() Thread.sleep(sleepMillis.toLong()) sink.writeUtf8("def") } catch (e: InterruptedException) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt
override fun contentType(): MediaType? { return null } @Throws( IOException::class, ) override fun writeTo(sink: BufferedSink) { for (i in 0..9) { sink.writeByte(0) sink.flush() sleep(100) }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 9.9K bytes - Viewed (0) -
src/cmd/gofmt/gofmt.go
fmt.Fprintf(r.getState().err, format, args...) } // Write emits a slice to the reporter's output stream. // // Any error is returned to the caller, and does not otherwise affect the // reporter's exit code. func (r *reporter) Write(p []byte) (int, error) { return r.getState().out.Write(p) } // Report emits a non-nil error to the reporter's error stream,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 19:41:17 UTC 2024 - 15.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
private val messageFrameBuffer = Buffer() /** Lazily initialized on first use. */ private var messageInflater: MessageInflater? = null // Masks are only a concern for server writers. private val maskKey: ByteArray? = if (isClient) null else ByteArray(4) private val maskCursor: Buffer.UnsafeCursor? = if (isClient) null else Buffer.UnsafeCursor() interface FrameCallback {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 9.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/InterceptorTest.kt
} override fun writeTo(sink: BufferedSink) { val uppercase = uppercase(sink) val bufferedSink = uppercase.buffer() original!!.writeTo(bufferedSink) bufferedSink.emit() } } } private fun uppercase(original: BufferedSink): Sink { return object : ForwardingSink(original) { override fun write( source: Buffer,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Jan 14 10:20:09 UTC 2024 - 27.8K bytes - Viewed (0) -
platforms/software/publish/src/main/java/org/gradle/api/publish/tasks/GenerateModuleMetadata.java
); } private void writeModuleMetadata(ModuleMetadataSpec moduleMetadataSpec) { try (Writer writer = bufferedWriterFor(outputFile.get().getAsFile())) { moduleMetadataWriter().writeTo(writer, moduleMetadataSpec); } catch (IOException e) { throw new UncheckedIOException("Could not generate metadata file " + outputFile.get(), e); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Dec 21 07:21:42 UTC 2023 - 12.1K bytes - Viewed (0) -
platforms/software/ivy/src/main/java/org/gradle/api/publish/ivy/internal/tasks/IvyDescriptorFileGenerator.java
this.model = model; this.xmlTransformer = xmlTransformer; } public void writeTo(File destination) { xmlTransformer.transform(destination, IVY_FILE_ENCODING, writer -> { try { new ModelWriter(model).writeDescriptor(writer); } catch (IOException e) { throw new UncheckedIOException(e); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 14:02:46 UTC 2023 - 14.3K bytes - Viewed (0) -
licenses/sigs.k8s.io/yaml/LICENSE
are still covered by their original MIT license, with the additional copyright staring in 2011 when the project was ported over: apic.go emitterc.go parserc.go readerc.go scannerc.go writerc.go yamlh.go yamlprivateh.go Copyright (c) 2006-2010 Kirill Simonov Copyright (c) 2006-2011 Kirill Simonov Permission is hereby granted, free of charge, to any person obtaining a copy of
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 19:53:28 UTC 2023 - 15.8K bytes - Viewed (0) -
platforms/software/maven/src/main/java/org/gradle/api/publish/maven/internal/tasks/MavenPomFileGenerator.java
this.model = model; this.xmlTransformer = xmlTransformer; } public void writeTo(File file) { xmlTransformer.transform(file, POM_FILE_ENCODING, writer -> { try { new MavenXpp3Writer().write(writer, model); } catch (IOException e) { throw new UncheckedIOException(e); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 14:02:46 UTC 2023 - 13.8K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectMaxNConcurrentRequests.java
} } if (cancelled) { return new ResponseProducer() { @Override public void writeTo(int requestId, HttpExchange exchange) { try { exchange.sendResponseHeaders(200, -1); } catch (IOException e) { // Ignore
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 14.4K bytes - Viewed (0)