ByteArrayInputStream - Code Search

platforms/core-runtime/io/src/test/groovy/org/gradle/internal/io/StreamByteBufferTest.groovy

    }

    def "reads source InputStream fully"() {
        given:
        def byteBuffer = new StreamByteBuffer()
        def byteArrayInputStream = new ByteArrayInputStream(testbuffer)

        when:
        byteBuffer.readFully(byteArrayInputStream)

        then:
        byteBuffer.totalBytesUnread() == testbuffer.length
        byteBuffer.readAsByteArray() == testbuffer
    }

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Fri Apr 12 13:06:08 UTC 2024

- 13.3K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/io/ByteStreamsTest.java

    byte[] bytes = newPreFilledByteArray(100);
    skipHelper(0, 0, new ByteArrayInputStream(bytes));
    skipHelper(50, 50, new ByteArrayInputStream(bytes));
    skipHelper(50, 50, new SlowSkipper(new ByteArrayInputStream(bytes), 1));
    skipHelper(50, 50, new SlowSkipper(new ByteArrayInputStream(bytes), 0));
    skipHelper(100, -1, new ByteArrayInputStream(bytes));

Registered: Wed Jun 12 16:38:11 UTC 2024

- Last Modified: Wed Sep 06 17:04:31 UTC 2023

- 21.9K bytes

- Viewed (0)

github.com/codelibs/fess-crawler

fess-crawler/src/test/java/org/codelibs/fess/crawler/client/storage/StorageClientTest.java

                .stream(new ByteArrayInputStream("file1".getBytes()), 5, -1).contentType("application/octet-stream").build());
        minioClient.putObject(PutObjectArgs.builder().bucket(bucketName).object("dir1/file2.txt")
                .stream(new ByteArrayInputStream("file2".getBytes()), 5, -1).contentType("application/octet-stream").build());

Registered: Wed Jun 12 15:17:51 UTC 2024

- Last Modified: Thu Feb 22 01:36:27 UTC 2024

- 13.5K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/software/dependency-management/src/test/groovy/org/gradle/internal/resource/transfer/DefaultCacheAwareExternalResourceAccessorTest.groovy

            ExternalResourceReadResult.of(1, t.transform(new ByteArrayInputStream("proc".bytes)))
        }
        1 * repository.withProgressLogging() >> progressLoggingRepo
        1 * progressLoggingRepo.resource(location, true) >> remoteResource
        1 * remoteResource.withContentIfPresent(_) >> { ExternalResource.ContentAndMetadataAction a ->
            a.execute(new ByteArrayInputStream(), remoteMetaData)
        }
        0 * _._

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Tue Jan 02 17:19:47 UTC 2024

- 19.1K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/io/ByteStreams.java

    return new ByteArrayDataInputStream(checkNotNull(byteArrayInputStream));
  }

  private static class ByteArrayDataInputStream implements ByteArrayDataInput {
    final DataInput input;

    ByteArrayDataInputStream(ByteArrayInputStream byteArrayInputStream) {
      this.input = new DataInputStream(byteArrayInputStream);
    }

    @Override

Registered: Wed Jun 12 16:38:11 UTC 2024

- Last Modified: Wed Jan 17 18:59:58 UTC 2024

- 29.7K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/io/ByteStreams.java

    return new ByteArrayDataInputStream(checkNotNull(byteArrayInputStream));
  }

  private static class ByteArrayDataInputStream implements ByteArrayDataInput {
    final DataInput input;

    ByteArrayDataInputStream(ByteArrayInputStream byteArrayInputStream) {
      this.input = new DataInputStream(byteArrayInputStream);
    }

    @Override

Registered: Wed Jun 12 16:38:11 UTC 2024

- Last Modified: Wed Jan 17 18:59:58 UTC 2024

- 29.7K bytes

- Viewed (0)

github.com/codelibs/fess

src/test/java/org/codelibs/fess/mylasta/direction/FessPropTest.java

        final DOMParser parser = new DOMParser();
        final String html = "<html><body>" + text + "</body></html>";
        final ByteArrayInputStream is = new ByteArrayInputStream(html.getBytes("UTF-8"));
        parser.parse(new InputSource(is));
        Node node = parser.getDocument().getFirstChild().getLastChild().getFirstChild();
        return tag.matches(node);
    }

Registered: Wed Jun 12 13:08:18 UTC 2024

- Last Modified: Thu Feb 22 01:37:57 UTC 2024

- 12.7K bytes

- Viewed (0)

github.com/gradle/gradle

subprojects/core/src/main/java/org/gradle/api/internal/file/archive/TarFileTree.java

import org.gradle.internal.file.Chmod;
import org.gradle.internal.hash.FileHasher;
import org.gradle.internal.hash.HashCode;
import org.gradle.util.internal.GFileUtils;

import java.io.BufferedInputStream;
import java.io.ByteArrayInputStream;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.util.Objects;
import java.util.concurrent.atomic.AtomicBoolean;

import static java.lang.String.format;

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Tue Mar 26 15:15:04 UTC 2024

- 9.8K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/helper/PluginHelper.java

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.helper;

import static org.codelibs.core.stream.StreamUtil.split;

import java.io.ByteArrayInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.Proxy;
import java.nio.file.Files;
import java.nio.file.Path;

Registered: Wed Jun 12 13:08:18 UTC 2024

- Last Modified: Thu Feb 22 01:37:57 UTC 2024

- 16.8K bytes

- Viewed (0)

github.com/codelibs/corelib

src/main/java/org/codelibs/core/xml/DomUtil.java

        assertArgumentNotNull("contents", contents);

        if (encoding == null) {
            return new ByteArrayInputStream(contents.getBytes());
        }
        try {
            return new ByteArrayInputStream(contents.getBytes(encoding));
        } catch (final UnsupportedEncodingException ex) {
            throw new IORuntimeException(ex);
        }
    }

    /**

Registered: Wed Jun 12 12:50:12 UTC 2024

- Last Modified: Thu Mar 07 01:59:08 UTC 2024

- 10.5K bytes

- Viewed (0)

Search Options