* limitations under the License.
 */

package com.google.common.io;

import com.google.common.base.Charsets;
import com.google.common.primitives.Bytes;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.DataInput;
import java.io.DataInputStream;
import java.io.IOException;
import junit.framework.TestCase;

/**

 * limitations under the License.
 */

package com.google.common.io;

import com.google.common.base.Charsets;
import com.google.common.primitives.Bytes;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.DataInput;
import java.io.DataInputStream;
import java.io.IOException;
import junit.framework.TestCase;

/**

 * limitations under the License.
 */

package org.gradle.internal.resource.local;

import org.gradle.internal.resource.ReadableContent;

import java.io.ByteArrayInputStream;
import java.io.InputStream;

public class ByteArrayReadableContent implements ReadableContent {
    private final byte[] source;

    public ByteArrayReadableContent(byte[] source) {

        def outputStream = new ByteArrayOutputStream()
        def encoder = new EncodedStream.EncodedOutput(outputStream)

        when:
        encoder.flush()

        then:
        def inputStream = new ByteArrayInputStream(outputStream.toByteArray())
        def decoder = new EncodedStream.EncodedInput(inputStream)
        decoder.read() < 0
    }

    def "can encode and decode a string"() {

    def "can hash input"() {
        def input = new ByteArrayInputStream("hello".bytes)
        when:
        def hash = new DefaultStreamHasher().hash(input)
        then:
        hash.toString() == "af67a92e9f73b51572e9b94e343d2840"
    }

    def "can hash input while copying it"() {
        def input = new ByteArrayInputStream("hello".bytes)
        def output = new ByteArrayOutputStream()
        when:

    @Override
    public V getIfPresent(K key) {
        byte[] serialised = entries.get(key);
        if (serialised == null) {
            return null;
        }
        try {
            ByteArrayInputStream instr = new ByteArrayInputStream(serialised);
            InputStreamBackedDecoder decoder = new InputStreamBackedDecoder(instr);
            return valueSerializer.read(decoder);
        } catch (Exception e) {

import java.io.ByteArrayInputStream;

class PublicKeySerializer extends AbstractSerializer<PGPPublicKey> {

    @Override
    public PGPPublicKey read(Decoder decoder) throws Exception {
        byte[] encoded = decoder.readBinary();
        PGPObjectFactory objectFactory = new PGPObjectFactory(
            PGPUtil.getDecoderStream(new ByteArrayInputStream(encoded)), new BcKeyFingerprintCalculator());

import java.io.ByteArrayInputStream;
import java.io.FilterReader;
import java.io.IOException;
import java.io.InputStreamReader;

/** @author Colin Decker */
public class TestReader extends FilterReader {

  private final TestInputStream in;

  public TestReader(TestOption... options) throws IOException {
    this(new TestInputStream(new ByteArrayInputStream(new byte[10]), options));
  }

import java.io.ByteArrayInputStream;
import java.io.FilterReader;
import java.io.IOException;
import java.io.InputStreamReader;

/** @author Colin Decker */
public class TestReader extends FilterReader {

  private final TestInputStream in;

  public TestReader(TestOption... options) throws IOException {
    this(new TestInputStream(new ByteArrayInputStream(new byte[10]), options));
  }

        and:
        0 * action._
    }

    def "reads empty content"() {
        setup:
        expectReadBuildOperation(0)
        expectResourceRead(new ByteArrayInputStream())

        when:
        def result = accessor.withContent(location, false, action)

        then:
        result == "result"

        and:
        1 * action.execute(_, _) >> "result"
    }