- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for StreamHandler (0.25 sec)
-
mockwebserver/src/main/kotlin/mockwebserver3/StreamHandler.kt
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 945 bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt
} /** Sets the response body to the UTF-8 encoded bytes of [body]. */ fun body(body: String): Builder = body(Buffer().writeUtf8(body)) fun streamHandler(streamHandler: StreamHandler) = apply { this.streamHandler = streamHandler } /** * Sets the response body to [body], chunked every [maxChunkSize] bytes. */ fun chunkedBody( body: Buffer,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 13.3K bytes - Viewed (1) -
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 =
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 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;
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Tue Jan 03 21:59:45 GMT 2023 - 12.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>()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 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...)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 08 18:15:27 GMT 2024 - 30.1K bytes - Viewed (0) -
internal/grid/handlers.go
// Buffers sent on out can not be referenced once sent. StreamHandlerFn func(ctx context.Context, payload []byte, in <-chan []byte, out chan<- []byte) *RemoteErr // StreamHandler handles fully bidirectional streams, // There is flow control in both directions. StreamHandler struct { // Handle an incoming request. Initial payload is sent. // Additional input packets (if any) are streamed to request.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 26.9K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
val bodyDelayNanos = response.bodyDelayNanos val trailers = response.trailers val body = response.body val streamHandler = response.streamHandler val outFinished = ( body == null && response.pushPromises.isEmpty() && streamHandler == null ) val flushHeaders = body == null || bodyDelayNanos != 0L require(!outFinished || trailers.size == 0) {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0) -
internal/grid/muxserver.go
LastPing: time.Now().Unix(), BaseFlags: c.baseFlags, } go func() { // TODO: Handle }() return &m } func newMuxStream(ctx context.Context, msg message, c *Connection, handler StreamHandler) *muxServer { var cancel context.CancelFunc ctx = setCaller(ctx, c.remote) if len(handler.Subroute) > 0 { ctx = setSubroute(ctx, handler.Subroute) } if msg.DeadlineMS > 0 {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0) -
internal/grid/benchmark_test.go
const responses = 10 // Create n managers. for _, remote := range grid.Managers { // Register a single handler which echos the payload. errFatal(remote.RegisterStreamingHandler(handlerTest, StreamHandler{ // Send 10x response. Handle: func(ctx context.Context, payload []byte, _ <-chan []byte, out chan<- []byte) *RemoteErr { for i := 0; i < responses; i++ { toSend := GetByteBuffer()[:0]
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 12.2K bytes - Viewed (0)