- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for OutputStreamBackedEncoder (0.46 sec)
-
platforms/core-runtime/serialization/src/main/java/org/gradle/internal/serialize/OutputStreamBackedEncoder.java
import java.io.Closeable; import java.io.DataOutputStream; import java.io.IOException; import java.io.OutputStream; public class OutputStreamBackedEncoder extends AbstractEncoder implements Closeable, FlushableEncoder { private final DataOutputStream outputStream; public OutputStreamBackedEncoder(OutputStream outputStream) { this.outputStream = new DataOutputStream(outputStream); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 15 16:06:56 UTC 2024 - 2.4K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/FileBackedObjectHolder.java
} chmod.chmod(cacheFile.getParentFile(), 0700); // read-write-execute for user only chmod.chmod(cacheFile, 0600); // read-write for user only OutputStreamBackedEncoder encoder = new OutputStreamBackedEncoder(new BufferedOutputStream(new FileOutputStream(cacheFile))); try { serializer.write(encoder, newValue); } finally { encoder.close();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:50 UTC 2024 - 4.7K bytes - Viewed (0) -
platforms/core-execution/worker-main/src/test/groovy/org/gradle/process/internal/worker/messaging/WorkerConfigSerializerTest.groovy
new TestAction("value"), NativeServicesMode.ENABLED ) when: ByteArrayOutputStream baos = new ByteArrayOutputStream() OutputStreamBackedEncoder encoder = new OutputStreamBackedEncoder(baos) new WorkerConfigSerializer().write(encoder, original) ByteArrayInputStream bais = new ByteArrayInputStream(baos.toByteArray())
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 05:58:56 UTC 2024 - 2.8K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/ivyservice/resolveengine/result/DependencyResultSerializerTest.groovy
import org.gradle.internal.resolve.ModuleVersionResolveException import org.gradle.internal.serialize.InputStreamBackedDecoder import org.gradle.internal.serialize.OutputStreamBackedEncoder import spock.lang.Specification import static org.gradle.api.internal.artifacts.DefaultModuleVersionSelector.newSelector class DependencyResultSerializerTest extends Specification {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 4.2K bytes - Viewed (0) -
platforms/extensibility/unit-test-fixtures/src/main/java/org/gradle/testfixtures/internal/TestInMemoryIndexedCache.java
}); } @Override public void put(K key, V value) { ByteArrayOutputStream outstr = new ByteArrayOutputStream(); OutputStreamBackedEncoder encoder = new OutputStreamBackedEncoder(outstr); try { valueSerializer.write(encoder, value); encoder.flush(); } catch (Exception e) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 13 21:54:27 UTC 2024 - 3.1K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/ivyservice/resolveengine/result/DummyBinaryStore.groovy
import org.gradle.internal.serialize.InputStreamBackedDecoder import org.gradle.internal.serialize.OutputStreamBackedEncoder class DummyBinaryStore implements BinaryStore { private final ByteArrayOutputStream bytes = new ByteArrayOutputStream() private Encoder output = new OutputStreamBackedEncoder(bytes) void write(WriteAction write) { write.write(output) } BinaryData done() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 1.6K bytes - Viewed (0) -
platforms/core-runtime/serialization/src/test/groovy/org/gradle/internal/serialize/StreamBackedCodecTest.groovy
package org.gradle.internal.serialize class StreamBackedCodecTest extends AbstractCodecTest { @Override void encodeTo(OutputStream outputStream, Closure<Encoder> closure) { def encoder = new OutputStreamBackedEncoder(outputStream) closure.call(encoder) } @Override void decodeFrom(InputStream inputStream, Closure<Decoder> closure) { def decoder = new InputStreamBackedDecoder(inputStream)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 15 16:06:56 UTC 2024 - 1.1K bytes - Viewed (0) -
platforms/jvm/language-java/src/test/groovy/org/gradle/api/internal/tasks/compile/incremental/deps/ClassSetAnalysisDataSerializerTest.groovy
import org.gradle.internal.hash.HashCode import org.gradle.internal.hash.TestHashCodes import org.gradle.internal.serialize.InputStreamBackedDecoder import org.gradle.internal.serialize.OutputStreamBackedEncoder import spock.lang.Specification import spock.lang.Subject import static org.gradle.api.internal.tasks.compile.incremental.compilerapi.deps.DependentsSet.dependencyToAll
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Feb 24 12:57:52 UTC 2024 - 2.9K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/worker/child/ApplicationClassesInSystemClassLoaderWorkerImplementationFactory.java
processBuilder.getNativeServicesMode() ); // Serialize the worker config, this is consumed by SystemApplicationClassLoaderWorker OutputStreamBackedEncoder encoder = new OutputStreamBackedEncoder(outstr); try { new WorkerConfigSerializer().write(encoder, config); } finally { encoder.flush(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 20 10:09:51 UTC 2024 - 9.7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/bootstrap/DaemonStartupCommunication.java
import org.gradle.internal.serialize.Decoder; import org.gradle.internal.serialize.FlushableEncoder; import org.gradle.internal.serialize.InputStreamBackedDecoder; import org.gradle.internal.serialize.OutputStreamBackedEncoder; import org.gradle.internal.stream.EncodedStream; import org.gradle.launcher.daemon.diagnostics.DaemonDiagnostics; import org.gradle.launcher.daemon.diagnostics.DaemonStartupInfo;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 4.7K bytes - Viewed (0)