- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 770 for Decoder (0.66 sec)
-
platforms/core-runtime/serialization/src/main/java/org/gradle/internal/serialize/Decoder.java
/** * Reads a byte stream written using {@link Encoder#encodeChunked(Encoder.EncodeAction)}. */ <T> T decodeChunked(DecodeAction<Decoder, T> decodeAction) throws EOFException, Exception; /** * Skips over a byte stream written using {@link Encoder#encodeChunked(Encoder.EncodeAction)}, discarding its content. */ void skipChunked() throws EOFException, IOException;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 15 16:06:56 UTC 2024 - 6.5K bytes - Viewed (0) -
src/encoding/gob/decoder.go
const tooBig = (1 << 30) << (^uint(0) >> 62) // A Decoder manages the receipt of type and data information read from the // remote side of a connection. It is safe for concurrent use by multiple // goroutines. // // The Decoder does only basic sanity checking on decoded input sizes, // and its limits are not configurable. Take caution when decoding gob data // from untrusted sources. type Decoder struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 08 19:04:28 UTC 2023 - 7.2K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/internal/snapshot/impl/ImplementationSnapshotSerializer.java
public ImplementationSnapshot read(Decoder decoder) throws Exception { Impl serializer = Impl.values()[decoder.readSmallInt()]; return serializer.read(decoder); } @Override public void write(Encoder encoder, ImplementationSnapshot implementationSnapshot) throws Exception { Impl serializer = determineSerializer(implementationSnapshot); encoder.writeSmallInt(serializer.ordinal());
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 24 12:33:49 UTC 2024 - 6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/serializer/streaming/streaming.go
base += n break } return d.decoder.Decode(d.buf[:base], defaults, into) } func (d *decoder) Close() error { return d.reader.Close() } type encoder struct { writer io.Writer encoder runtime.Encoder buf *bytes.Buffer } // NewEncoder returns a new streaming encoder. func NewEncoder(w io.Writer, e runtime.Encoder) Encoder { return &encoder{ writer: w, encoder: e,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 25 14:51:36 UTC 2023 - 3.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/serializer/recognizer/recognizer.go
} // NewDecoder creates a decoder that will attempt multiple decoders in an order defined // by: // // 1. The decoder implements RecognizingDecoder and identifies the data // 2. All other decoders, and any decoder that returned true for unknown. // // The order passed to the constructor is preserved within those priorities. func NewDecoder(decoders ...runtime.Decoder) runtime.Decoder { return &decoder{ decoders: decoders,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 19 21:24:36 UTC 2021 - 3.5K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/InterHubMessageSerializer.java
} @Override public ObjectReader<InterHubMessage> newReader(Decoder decoder) { return new MessageReader(decoder, payloadSerializer.newReader(decoder)); } @Override public ObjectWriter<InterHubMessage> newWriter(Encoder encoder) { return new MessageWriter(encoder, payloadSerializer.newWriter(encoder)); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/context/DefaultDaemonContext.java
@Override public DefaultDaemonContext read(Decoder decoder) throws Exception { String uid = decoder.readNullableString(); String pathname = decoder.readString(); File javaHome = new File(pathname); JavaLanguageVersion javaVersion = JavaLanguageVersion.of(decoder.readSmallInt()); File registryDir = new File(decoder.readString());
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 05:16:16 UTC 2024 - 6.8K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/stream/EncodedStreamTest.groovy
new String(content) == "this is some content" } def "can encode and decode binary content"() { def outputStream = new ByteArrayOutputStream() def encoder = new EncodedStream.EncodedOutput(outputStream) when: encoder.write(0) encoder.write(127) encoder.write(128) encoder.write(255) encoder.flush() then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 2.2K bytes - Viewed (0) -
platforms/native/language-native/src/main/java/org/gradle/language/nativeplatform/internal/incremental/CompilationStateSerializer.java
IncludeFileEdge includeFileState = ids.get(id); if (includeFileState == null) { String includePath = decoder.readString(); HashCode includedBy = null; if (decoder.readBoolean()) { includedBy = hashSerializer.read(decoder); } HashCode resolvedTo = hashSerializer.read(decoder);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 16 20:20:03 UTC 2023 - 4.8K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/MethodInvocationSerializer.java
} @Override public ObjectReader<MethodInvocation> newReader(Decoder decoder) { return new MethodInvocationReader(decoder, classLoader, methodArgsSerializer); } @Override public ObjectWriter<MethodInvocation> newWriter(Encoder encoder) { return new MethodInvocationWriter(encoder, methodArgsSerializer); } private static class MethodDetails {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 6.6K bytes - Viewed (0)