- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 797 for writeln (0.16 sec)
-
internal/bucket/replication/datatypes_gen.go
if err != nil { err = msgp.WrapError(err) return } (*z) = Type(zb0001) } return } // EncodeMsg implements msgp.Encodable func (z Type) EncodeMsg(en *msgp.Writer) (err error) { err = en.WriteInt(int(z)) if err != nil { err = msgp.WrapError(err) return } return } // MarshalMsg implements msgp.Marshaler func (z Type) MarshalMsg(b []byte) (o []byte, err error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 2.3K bytes - Viewed (0) -
src/bufio/bufio.go
// accepted and all subsequent writes, and [Writer.Flush], will return the error. // After all data has been written, the client should call the // [Writer.Flush] method to guarantee all data has been forwarded to // the underlying [io.Writer]. type Writer struct { err error buf []byte n int wr io.Writer }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Oct 12 14:39:08 GMT 2023 - 21.8K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockResponseBody.kt
* * Unlike [okhttp3.ResponseBody], this interface is designed to be implemented by writers and not * called by readers. */ @ExperimentalOkHttpApi interface MockResponseBody { /** The length of this response in bytes, or -1 if unknown. */ val contentLength: Long @Throws(IOException::class) fun writeTo(sink: BufferedSink)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 1.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
} if (associatedStreamId == 0) { writer.headers(outFinished, streamId, requestHeaders) } else { require(!client) { "client streams shouldn't have associated stream IDs" } // HTTP/2 has a PUSH_PROMISE frame. writer.pushPromise(associatedStreamId, streamId, requestHeaders) } } if (flushHeaders) { writer.flush() } return stream }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/ByteStreamsTest.java
} public void testNewDataOutput_writeInt() { ByteArrayDataOutput out = ByteStreams.newDataOutput(); out.writeInt(0x12345678); out.writeInt(0x76543210); assertThat(out.toByteArray()).isEqualTo(bytes); } public void testNewDataOutput_sized() { ByteArrayDataOutput out = ByteStreams.newDataOutput(4); out.writeInt(0x12345678); out.writeInt(0x76543210);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 21.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/SourceSinkFactories.java
public CharSink createSink() throws IOException { File file = createFile(); if (initialString != null) { Writer writer = new OutputStreamWriter(new FileOutputStream(file), Charsets.UTF_8); try { writer.write(initialString); } finally { writer.close(); } return Files.asCharSink(file, Charsets.UTF_8, FileWriteMode.APPEND); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Apr 06 12:56:11 GMT 2023 - 12.7K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Serialization.java
Multiset<E> multiset, ObjectOutputStream stream) throws IOException { int entryCount = multiset.entrySet().size(); stream.writeInt(entryCount); for (Multiset.Entry<E> entry : multiset.entrySet()) { stream.writeObject(entry.getElement()); stream.writeInt(entry.getCount()); } } /** * Populates a multiset by reading an input stream, as part of deserialization. See {@link
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Mar 06 16:06:58 GMT 2023 - 8.5K bytes - Viewed (0) -
cmd/batch-job-common-types_gen.go
func (z BatchJobRetry) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 2 // write "Attempts" err = en.Append(0x82, 0xa8, 0x41, 0x74, 0x74, 0x65, 0x6d, 0x70, 0x74, 0x73) if err != nil { return } err = en.WriteInt(z.Attempts) if err != nil { err = msgp.WrapError(err, "Attempts") return } // write "Delay" err = en.Append(0xa5, 0x44, 0x65, 0x6c, 0x61, 0x79)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 02 10:51:33 GMT 2023 - 21.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
outFrames.add(OutFrame(frameCount++, bytesOut.size, false)) return writer } /** * Shortens the last frame from its original length to `length`. This will cause the peer to * close the socket as soon as this frame has been written; otherwise the peer stays open until * explicitly closed. */ fun truncateLastFrame(length: Int): Http2Writer { val lastFrame = outFrames.removeAt(outFrames.size - 1)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
if err == nil || err == io.EOF && n > 0 { d.tracker.logSuccess() } return n, err } func (d *diskHealthWrapper) Write(p []byte) (int, error) { if d.w == nil { return 0, fmt.Errorf("diskHealthWrapper: Write with no writer") } n, err := d.w.Write(p) if err == nil && n == len(p) { d.tracker.logSuccess() } return n, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0)