- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 34 for stream_handle_ (0.35 sec)
-
okhttp/src/test/java/okhttp3/DuplexTest.kt
.streamHandler(body1) .build(), ) val body = MockStreamHandler() .sendResponse("response body\n") .exhaustResponse() .receiveRequest("request body\n") .exhaustRequest() server.enqueue( MockResponse.Builder() .clearHeaders() .streamHandler(body) .build(), ) val call =
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 23.9K bytes - Viewed (0) -
mockwebserver/api/mockwebserver3.api
public final fun status (Ljava/lang/String;)Lmockwebserver3/MockResponse$Builder; public final fun streamHandler (Lmockwebserver3/StreamHandler;)Lmockwebserver3/MockResponse$Builder; public final fun throttleBody (JJLjava/util/concurrent/TimeUnit;)Lmockwebserver3/MockResponse$Builder; public final fun trailers (Lokhttp3/Headers;)Lmockwebserver3/MockResponse$Builder;
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Jan 03 21:59:45 UTC 2023 - 12.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/DefaultExecHandle.java
/** * The variables to set in the environment the executable is run in. */ private final Map<String, String> environment; private final StreamsHandler outputHandler; private final StreamsHandler inputHandler; private final boolean redirectErrorStream; private final ProcessLauncher processLauncher; private int timeoutMillis; private boolean daemon; /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 26 14:58:23 UTC 2024 - 15.2K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/streams/EmptyStdInStreamsHandler.java
import org.gradle.api.UncheckedIOException; import org.gradle.process.internal.StreamsHandler; import java.io.IOException; import java.util.concurrent.Executor; /** * A handler that writes nothing to the process' stdin */ public class EmptyStdInStreamsHandler implements StreamsHandler { @Override public void connectStreams(Process process, String processName, Executor executor) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jul 11 16:06:58 UTC 2023 - 1.4K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/streams/ForwardStdinStreamsHandler.java
* limitations under the License. */ package org.gradle.process.internal.streams; import org.gradle.api.UncheckedIOException; import org.gradle.internal.UncheckedException; import org.gradle.process.internal.StreamsHandler; import org.gradle.util.internal.DisconnectableInputStream; import java.io.IOException; import java.io.InputStream; import java.util.concurrent.CountDownLatch; import java.util.concurrent.Executor; /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jul 11 16:06:58 UTC 2023 - 2.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/streams/OutputStreamsForwarder.java
import org.gradle.process.internal.StreamsHandler; import java.io.OutputStream; import java.util.concurrent.CountDownLatch; import java.util.concurrent.Executor; /** * Reads from the process' stdout and stderr (if not merged into stdout) and forwards to {@link OutputStream}. */ public class OutputStreamsForwarder implements StreamsHandler { private final OutputStream standardOutput;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jul 11 16:06:58 UTC 2023 - 3.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/bootstrap/DaemonOutputConsumer.java
import org.gradle.api.logging.Logger; import org.gradle.api.logging.Logging; import org.gradle.process.internal.StreamsHandler; import java.io.InputStream; import java.io.PrintWriter; import java.io.StringWriter; import java.util.Scanner; import java.util.concurrent.Executor; public class DaemonOutputConsumer implements StreamsHandler { private final static Logger LOGGER = Logging.getLogger(DaemonOutputConsumer.class);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 2.7K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/duplex/MockStreamHandler.kt
import java.util.concurrent.TimeUnit import mockwebserver3.Stream import mockwebserver3.StreamHandler import okio.utf8Size private typealias Action = (Stream) -> Unit /** * A scriptable request/response conversation. Create the script by calling methods like * [receiveRequest] in the sequence they are run. */ class MockStreamHandler : StreamHandler { private val actions = LinkedBlockingQueue<Action>()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.2K bytes - Viewed (0) -
internal/grid/grid_test.go
} } // We fake a local and remote server. remoteHost := remote.HostName() // 1: Echo register := func(manager *Manager) { errFatal(manager.RegisterStreamingHandler(handlerTest, StreamHandler{ Handle: func(ctx context.Context, payload []byte, request <-chan []byte, resp chan<- []byte) *RemoteErr { for in := range request { b := append([]byte{}, payload...) b = append(b, in...)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 36.4K bytes - Viewed (0) -
pkg/adsc/adsc_test.go
"istio.io/istio/pkg/test/util/retry" ) type testAdscRunServer struct{} var StreamHandler func(stream discovery.AggregatedDiscoveryService_StreamAggregatedResourcesServer) error func (t *testAdscRunServer) StreamAggregatedResources(stream discovery.AggregatedDiscoveryService_StreamAggregatedResourcesServer) error { return StreamHandler(stream) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 19 22:42:42 UTC 2023 - 15.4K bytes - Viewed (0)