- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 85 for ByteArrayInputStream (0.21 sec)
-
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/DaemonClientTest.groovy
final ProcessEnvironment processEnvironment = Mock() final GlobalUserInputReceiver userInput = Stub() final DaemonClient client = new DaemonClient(connector, outputEventListener, compatibilitySpec, new ByteArrayInputStream(new byte[0]), userInput, idGenerator, processEnvironment) def "executes action"() { def resultMessage = Stub(BuildActionResult) when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 10K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/reflect/ClassPathTest.java
import com.google.common.reflect.ClassPath.ClassInfo; import com.google.common.reflect.ClassPath.ResourceInfo; import com.google.common.testing.EqualsTester; import com.google.common.testing.NullPointerTester; import java.io.ByteArrayInputStream; import java.io.File; import java.io.FileOutputStream; import java.io.FilePermission; import java.io.IOException; import java.io.InputStream; import java.net.MalformedURLException;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Apr 26 14:02:27 UTC 2024 - 24.9K bytes - Viewed (0) -
platforms/core-execution/workers/src/test/groovy/org/gradle/workers/internal/IsolatableSerializerRegistryTest.groovy
encoder.flush() } Isolatable<?>[] deserialize() { def isolatables = [] def decoder = new KryoBackedDecoder(new ByteArrayInputStream(outputStream.toByteArray())); int size = decoder.readInt() size.times { isolatables.add(serializer.readIsolatable(decoder)) } return isolatables as Isolatable<?>[]
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 08 14:30:36 UTC 2024 - 11.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/tls/HostnameVerifierTest.kt
import assertk.assertions.containsExactly import assertk.assertions.isEqualTo import assertk.assertions.isFalse import assertk.assertions.isInstanceOf import assertk.assertions.isTrue import java.io.ByteArrayInputStream import java.security.cert.CertificateFactory import java.security.cert.X509Certificate import javax.net.ssl.SSLSession import javax.security.auth.x500.X500Principal import okhttp3.FakeSSLSession
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 40.3K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/extractor/impl/TikaExtractorTest.java
* either express or implied. See the License for the specific language * governing permissions and limitations under the License. */ package org.codelibs.fess.crawler.extractor.impl; import java.io.ByteArrayInputStream; import java.io.InputStream; import java.io.UnsupportedEncodingException; import java.util.HashMap; import java.util.Map; import org.codelibs.core.io.CloseableUtil; import org.codelibs.core.io.ResourceUtil;
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 30.5K bytes - Viewed (0) -
platforms/core-runtime/serialization/src/test/groovy/org/gradle/internal/serialize/AbstractCodecTest.groovy
} abstract void decodeFrom(InputStream inputStream, Closure<Decoder> closure) void decode(byte[] bytes, Closure<Decoder> closure) { decodeFrom(new ByteArrayInputStream(bytes), closure) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 15 16:06:56 UTC 2024 - 14.9K bytes - Viewed (0) -
platforms/core-runtime/io/src/main/java/org/gradle/internal/io/StreamByteBuffer.java
import java.util.LinkedList; import java.util.List; /** * An in-memory buffer that provides OutputStream and InputStream interfaces. * * This is more efficient than using ByteArrayOutputStream/ByteArrayInputStream * * Reading the buffer will clear the buffer. * This is not thread-safe, it is intended to be used by a single Thread. */ public class StreamByteBuffer { private static final int DEFAULT_CHUNK_SIZE = 4096;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 08:51:14 UTC 2024 - 16.6K bytes - Viewed (0) -
platforms/core-runtime/serialization/src/test/groovy/org/gradle/internal/serialize/MessageTest.groovy
} private Object transport(Object arg) { def outputStream = new ByteArrayOutputStream() Message.send(new TestPayloadMessage(payload: arg), outputStream) def inputStream = new ByteArrayInputStream(outputStream.toByteArray()) def message = Message.receive(inputStream, dest) return message.payload } static class TestPayloadMessage implements Serializable { def payload
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 15 16:06:56 UTC 2024 - 16.4K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcHttpClient.java
* either express or implied. See the License for the specific language * governing permissions and limitations under the License. */ package org.codelibs.fess.crawler.client.http; import java.io.ByteArrayInputStream; import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.net.ConnectException; import java.net.MalformedURLException;
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu May 09 09:28:25 UTC 2024 - 41K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
* uncompilable code).) */ package com.google.common.util.concurrent; import static java.util.concurrent.TimeUnit.MILLISECONDS; import static java.util.concurrent.TimeUnit.NANOSECONDS; import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; import java.io.ObjectInputStream; import java.io.ObjectOutputStream; import java.security.CodeSource; import java.security.Permission;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 17:15:24 UTC 2024 - 37.7K bytes - Viewed (0)