}

    <T extends CommonServerMessageBlockResponse> T send(CommonServerMessageBlockRequest request, T response) throws CIFSException {
        return send(request, response, Collections.<RequestParam> emptySet());
    }

    <T extends CommonServerMessageBlockResponse> T send(CommonServerMessageBlockRequest request, T response, Set<RequestParam> params)
            throws CIFSException {

        throw new DfsReferral(dr);
    }

    <T extends CommonServerMessageBlockResponse> T send(final CommonServerMessageBlockRequest request, final T response)
            throws SmbException {
        return send(request, response, Collections.<RequestParam> emptySet());
    }

    <T extends CommonServerMessageBlockResponse> T send(final CommonServerMessageBlockRequest request, T response,

labels.chat_step_intent=Analyze
labels.chat_step_search=Search
labels.chat_step_evaluate=Evaluate
labels.chat_step_fetch=Retrieve
labels.chat_step_answer=Answer
labels.chat_input_hint=Press Enter to send, Shift+Enter for new line
labels.chat_send=Send message
labels.chat_retry=Retry
labels.chat_dismiss=Dismiss
labels.chat_copied=Copied!
labels.chat_copy_failed=Copy failed

labels.chat_filter=Filter

					perDiskLimit:   opts.Limit,
					minDisks:       listingQuorum,
					reportNotFound: false,
					agreed:         send,
					partial: func(entries metaCacheEntries, _ []error) {
						entry, ok := entries.resolve(&resolver)
						if ok {
							send(*entry)
						}
					},
					finished: nil,
				}

				if err := listPathRaw(ctx, lopts); err != nil {

labels.chat_step_intent=Analyze
labels.chat_step_search=Search
labels.chat_step_evaluate=Evaluate
labels.chat_step_fetch=Retrieve
labels.chat_step_answer=Answer
labels.chat_input_hint=Press Enter to send, Shift+Enter for new line
labels.chat_send=Send message
labels.chat_retry=Retry
labels.chat_dismiss=Dismiss
labels.chat_copied=Copied!
labels.chat_copy_failed=Copy failed
labels.chat_filter=Filter

 *  **Web Sockets are now a stable feature of OkHttp.** Since being introduced as a beta feature in
    OkHttp 2.3 our web socket client has matured. Connect to a server's web socket with
    `OkHttpClient.newWebSocket()`, send messages with `send()`, and receive messages with the
    `WebSocketListener`.

    The `okhttp-ws` submodule is no longer available and `okhttp-ws` artifacts from previous

import okhttp3.internal.ws.RealWebSocket
import okio.Sink
import okio.Source
import org.codehaus.mojo.animal_sniffer.IgnoreJRERequirement

/**
 * Factory for [calls][Call], which can be used to send HTTP requests and read their responses.
 *
 * ## OkHttpClients Should Be Shared
 *
 * OkHttp performs best when you create a single `OkHttpClient` instance and reuse it for all of

    peer.sendFrame().settings(Settings())
    peer.acceptFrame() // ACK
    peer.acceptFrame() // SYN_STREAM
    peer.sendFrame().headers(false, 3, headerEntries("a", "android"))
    for (i in 0..2) {
      // Send frames of summing to size 50, which is windowUpdateThreshold.
      peer.sendFrame().data(false, 3, data(24), 24)
      peer.sendFrame().data(false, 3, data(25), 25)
      peer.sendFrame().data(false, 3, data(1), 1)

		// Marker being set to a value which is greater than and all object names when sorted (36).
		// Expected to send an empty response in this case.
		{"test-bucket-list-object", "", "zen", "", 10, ListObjectsInfo{}, nil, true},
		// Marker being set to a value which is lesser than and all object names when sorted (37).
		// Expected to send all the objects in the bucket in this case.

    val webSocket =
      object : WebSocket {
        override fun request(): Request = TODO()

        override fun queueSize(): Long = TODO()

        override fun send(text: String): Boolean = TODO()

        override fun send(bytes: ByteString): Boolean = TODO()

        override fun close(
          code: Int,
          reason: String?,
        ): Boolean = TODO()