accessResultData.setData("xyz".getBytes());

        final Object obj = binaryTransformer.getData(accessResultData);
        assertNotNull(obj);
        assertTrue(obj instanceof InputStream);
        assertEquals("xyz", new String(IOUtils.toByteArray((InputStream) obj)));
    }

    public void test_getData_wrongName() throws Exception {
        final AccessResultDataImpl accessResultData = new AccessResultDataImpl();

                URL resource = resources.nextElement();
                try {
                    InputStream is = resource.openStream();
                    final Properties properties = new Properties();
                    if (is != null) {
                        try (InputStream in = is) {
                            properties.load(in);
                        }
                    }

import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;

import org.codelibs.core.io.FileUtil;

/**
 * A custom InputStream that wraps a temporary file. This class ensures that the temporary file
 * is deleted when the stream is closed.
 */
public class TemporaryFileInputStream extends InputStream {

    private final File tempFile;

    private final FileInputStream fileInputStream;

        }
    }

    public Settings read(InputStream in, boolean strict) throws IOException, XmlPullParserException {
        try {
            return new Settings(delegate.read(in, strict, null));
        } catch (XMLStreamException e) {
            throw new XmlPullParserException(e.getMessage(), null, e);
        }
    }

    public Settings read(InputStream in) throws IOException, XmlPullParserException {
        try {

 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */
package jcifs;

import java.io.InputStream;
import java.io.OutputStream;

/**
 * Handle to an open named pipe
 *
 * @author mbechler
 *
 */
public interface SmbPipeHandle extends AutoCloseable {

    /**

 * specific language governing permissions and limitations
 * under the License.
 */
package org.apache.maven.project;

import java.io.ByteArrayInputStream;
import java.io.InputStream;
import java.nio.charset.StandardCharsets;
import java.util.Arrays;

import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;

 * 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.InputStream;
import java.util.HashMap;
import java.util.Map;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.codelibs.core.io.CloseableUtil;

            when(mockResource.openInputStream(anyInt(), anyInt(), anyInt())).thenReturn(mockInputStream);

            // When
            InputStream is1 = mockResource.openInputStream();
            InputStream is2 = mockResource.openInputStream(1);
            InputStream is3 = mockResource.openInputStream(1, 2, 3);

            // Then
            assertNotNull(is1, "Default input stream should not be null");

import javax.inject.Named;
import javax.xml.stream.XMLInputFactory;
import javax.xml.stream.XMLStreamException;
import javax.xml.stream.XMLStreamReader;

import java.io.IOException;
import java.io.InputStream;
import java.nio.file.Files;
import java.nio.file.Path;

/**
 * @deprecated use {@code org.apache.maven.api.services.model.RootLocator} instead
 */
@Named
@Deprecated(since = "4.0.0")

import java.io.FilterInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.Random;
import org.jspecify.annotations.NullUnmarked;

/** Returns a random portion of the requested bytes on each call. */
@NullUnmarked
class RandomAmountInputStream extends FilterInputStream {
  private final Random random;

  public RandomAmountInputStream(InputStream in, Random random) {
    super(checkNotNull(in));