Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for writeRequest (0.07 sec)

  2. github.com/codelibs/jcifs

    src/test/java/jcifs/internal/smb2/io/Smb2WriteRequestTest.java 

            void testConstructor() {
            Smb2WriteRequest writeRequest = new Smb2WriteRequest(mockConfig, testFileId);
            assertNotNull(writeRequest);
            assertTrue(writeRequest instanceof ServerMessageBlock2Request);
            assertTrue(writeRequest instanceof RequestWithFileId);
        }

        @Test
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  3. github.com/codelibs/jcifs

    src/test/java/jcifs/internal/smb2/RequestWithFileIdTest.java 

            RequestWithFileId queryDirRequest = new Smb2QueryDirectoryRequest(mockConfig, testFileId);
        RequestWithFileId readRequest = new Smb2ReadRequest(mockConfig, testFileId, testOutputBuffer, 0);
        RequestWithFileId writeRequest = new Smb2WriteRequest(mockConfig, testFileId);
        RequestWithFileId flushRequest = new Smb2FlushRequest(mockConfig, testFileId);
        RequestWithFileId ioctlRequest = new Smb2IoctlRequest(mockConfig, 0x00090000, testFileId);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 11.9K bytes
    - Viewed (0)
  4. github.com/square/okhttp

    okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt 

    import okio.Sink
import okio.Source
import okio.Timeout

/**
 * A socket connection that can be used to send HTTP/1.1 messages. This class strictly enforces the
 * following lifecycle:
 *
 *  1. [Send request headers][writeRequest].
 *  2. Open a sink to write the request body. Either [known][newKnownLengthSink] or
 *     [chunked][newChunkedSink].
 *  3. Write to and then close that sink.
 *  4. [Read response headers][readResponseHeaders].
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 17.5K bytes
    - Viewed (7)
  5. github.com/square/okhttp

    okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt 

            )
      socket.source.timeout().timeout(readTimeoutMillis.toLong(), TimeUnit.MILLISECONDS)
      socket.sink.timeout().timeout(writeTimeoutMillis.toLong(), TimeUnit.MILLISECONDS)
      tunnelCodec.writeRequest(nextRequest.headers, requestLine)
      tunnelCodec.finishRequest()
      val response =
        tunnelCodec
          .readResponseHeaders(false)!!
          .request(nextRequest)
          .build()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 18.6K bytes
    - Viewed (0)
  6. github.com/codelibs/fess-crawler

    fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java 

    import org.opensearch.action.bulk.BulkRequestBuilder;
import org.opensearch.action.bulk.BulkResponse;
import org.opensearch.action.search.SearchResponse;
import org.opensearch.action.support.WriteRequest.RefreshPolicy;
import org.opensearch.action.update.UpdateRequestBuilder;
import org.opensearch.common.unit.TimeValue;
import org.opensearch.index.query.QueryBuilders;
import org.opensearch.search.SearchHit;
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 17K bytes
    - Viewed (0)
  7. github.com/codelibs/fess-suggest

    src/test/java/org/codelibs/fess/suggest/SuggesterTest.java 

    import org.opensearch.action.bulk.BulkRequestBuilder;
import org.opensearch.action.index.IndexAction;
import org.opensearch.action.index.IndexRequestBuilder;
import org.opensearch.action.support.WriteRequest;
import org.opensearch.transport.client.Client;

public class SuggesterTest {
    static Suggester suggester;

    static OpenSearchRunner runner;

    @BeforeClass
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 37.2K bytes
    - Viewed (0)
  8. github.com/codelibs/fess-crawler

    fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java 

    import org.opensearch.action.index.IndexResponse;
import org.opensearch.action.search.SearchRequestBuilder;
import org.opensearch.action.search.SearchResponse;
import org.opensearch.action.support.WriteRequest.RefreshPolicy;
import org.opensearch.action.support.clustermanager.AcknowledgedResponse;
import org.opensearch.cluster.metadata.MappingMetadata;
import org.opensearch.common.unit.TimeValue;
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 34.2K bytes
    - Viewed (0)
  9. github.com/codelibs/fess

    src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java 

    import org.opensearch.action.search.SearchResponse;
import org.opensearch.action.search.SearchScrollRequest;
import org.opensearch.action.search.SearchScrollRequestBuilder;
import org.opensearch.action.support.WriteRequest.RefreshPolicy;
import org.opensearch.action.support.clustermanager.AcknowledgedResponse;
import org.opensearch.action.termvectors.MultiTermVectorsRequest;
import org.opensearch.action.termvectors.MultiTermVectorsRequestBuilder;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sun Aug 31 08:19:00 UTC 2025
    - 121.9K bytes
    - Viewed (0)
  10. github.com/golang/go

    api/go1.7.txt 

    pkg net/http/httptrace, type ClientTrace struct, Wait100Continue func()
pkg net/http/httptrace, type ClientTrace struct, WroteHeaders func()
pkg net/http/httptrace, type ClientTrace struct, WroteRequest func(WroteRequestInfo)
pkg net/http/httptrace, type DNSDoneInfo struct
pkg net/http/httptrace, type DNSDoneInfo struct, Addrs []net.IPAddr
pkg net/http/httptrace, type DNSDoneInfo struct, Coalesced bool
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Jun 28 15:08:11 UTC 2016
    - 13.6K bytes
    - Viewed (0)
  11. github.com/golang/go

    api/go1.txt 

    pkg net/rpc, type ClientCodec interface { Close, ReadResponseBody, ReadResponseHeader, WriteRequest }
pkg net/rpc, type ClientCodec interface, Close() error
pkg net/rpc, type ClientCodec interface, ReadResponseBody(interface{}) error
pkg net/rpc, type ClientCodec interface, ReadResponseHeader(*Response) error
pkg net/rpc, type ClientCodec interface, WriteRequest(*Request, interface{}) error
pkg net/rpc, type Request struct
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
Back to top