Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 203 for ByteArrayInputStream (0.33 sec)

  2. github.com/gradle/gradle

    platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/cli/WelcomeMessageActionTest.groovy 

            return new WelcomeMessageAction(log, buildLayout, welcomeMessageConfiguration, gradleVersion, { welcomeMessage == null ? null : new ByteArrayInputStream(welcomeMessage.bytes) } as Function, delegateAction)
    }

    def "prints highlights when file exists and contains visible content"() {
        given:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:29:13 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  3. github.com/gradle/gradle

    platforms/jvm/normalization-java/src/main/java/org/gradle/api/internal/changedetection/state/FallbackHandlingResourceHasher.java 

    import org.gradle.internal.io.IoFunction;
import org.gradle.internal.io.IoSupplier;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import javax.annotation.Nullable;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.Optional;
import java.util.function.Supplier;

abstract class FallbackHandlingResourceHasher implements ResourceHasher {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Sep 28 15:09:49 UTC 2023
    - 6K bytes
    - Viewed (0)
  4. 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)
  5. github.com/gradle/gradle

    platforms/software/resources-http/src/test/groovy/org/gradle/internal/resource/transport/http/HttpResourceListerTest.groovy 

        ExternalResourceMetaData metaData = Mock()
    HttpResourceLister lister = new HttpResourceLister(accessorMock)

    def "parses resource content"() {
        setup:
        def inputStream = new ByteArrayInputStream("<a href='child'/>".bytes)
        def name = new ExternalResourceName("http://testrepo/")

        when:
        lister.list(name)
        then:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Oct 12 19:38:08 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  6. github.com/gradle/gradle

    platforms/ide/tooling-api/src/testFixtures/groovy/org/gradle/integtests/tooling/fixture/ConfigurableOperation.groovy 

            return OutputScrapingExecutionResult.from(standardOutput, standardError)
    }

    ConfigurableOperation setStandardInput(String input) {
        this.operation.standardInput = new ByteArrayInputStream(input.toString().bytes)
        return this
    }

    List getProgressMessages() {
        return progressMessages
    }

    ConfigurableOperation buildModel() {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Sep 26 14:49:20 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  7. github.com/gradle/gradle

    subprojects/core/src/test/groovy/org/gradle/configuration/project/PluginsProjectConfigureActionsTest.groovy 

            URLConnection connection = Mock()
        URL url = new URL("custom", "host", 12, "file", handler)
        _ * handler.openConnection(url) >> connection
        _ * connection.getInputStream() >> new ByteArrayInputStream("ConfigureActionClass".bytes)
        return Collections.enumeration([url])
    }

    static class TestConfigureAction implements ProjectConfigureAction {
        void execute(ProjectInternal project) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jan 24 17:10:43 UTC 2017
    - 2.1K bytes
    - Viewed (0)
  8. github.com/gradle/gradle

    platforms/core-runtime/logging/src/test/groovy/org/gradle/internal/logging/serializer/LogSerializerSpec.groovy 

            return fromBytes(bytes, serializer)
    }

    public <T> T fromBytes(byte[] bytes, Serializer<T> serializer) {
        return serializer.read(new KryoBackedDecoder(new ByteArrayInputStream(bytes)))
    }

    public <T> byte[] toBytes(T value, Serializer<T> serializer) {
        def bytes = new ByteArrayOutputStream()
        def encoder = new KryoBackedEncoder(bytes)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:05:18 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  9. github.com/gradle/gradle

    subprojects/core/src/test/groovy/org/gradle/process/internal/DefaultExecHandleBuilderTest.groovy 

            expect:
        builder.standardInput.read() < 0
        builder.inputHandler instanceof EmptyStdInStreamsHandler
    }

    def canAttachAStandardInputStream() {
        def inputStream = new ByteArrayInputStream()

        when:
        builder.standardInput = inputStream

        then:
        builder.standardInput == inputStream
        builder.inputHandler instanceof ForwardStdinStreamsHandler
    }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jun 29 07:54:38 UTC 2018
    - 2K bytes
    - Viewed (0)
  10. 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)
  11. github.com/gradle/gradle

    platforms/core-execution/build-cache/src/test/groovy/org/gradle/caching/internal/controller/service/LoadTargetTest.groovy 

            then:
        input.closed
    }

    def "closes input on subsequent use"() {
        given:
        def input = new TestInputStream()

        when:
        target.readFrom(new ByteArrayInputStream([] as byte[]))
        target.readFrom(input)

        then:
        thrown IllegalStateException
        input.closed
    }

    def "closes input on error"() {
        given:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:43:12 UTC 2023
    - 2.1K bytes
    - Viewed (0)
Back to top