responseCh - Code Search

src/main/java/jcifs/smb1/ntlmssp/Type2Message.java

    }

    /**
     * Creates a Type-2 message in response to the given Type-1 message
     * using default values from the current environment.
     *
     * @param type1 The Type-1 message which this represents a response to.
     */
    public Type2Message(Type1Message type1) {
        this(type1, null, null);
    }

    /**
     * Creates a Type-2 message in response to the given Type-1 message.
     *

Registered: Sun Nov 03 00:10:13 UTC 2024

- Last Modified: Fri Mar 22 20:39:42 UTC 2019

- 12.6K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs_src/request_files/tutorial002_an.py

from typing import List

from fastapi import FastAPI, File, UploadFile
from fastapi.responses import HTMLResponse
from typing_extensions import Annotated

app = FastAPI()


@app.post("/files/")
async def create_files(files: Annotated[List[bytes], File()]):
    return {"file_sizes": [len(file) for file in files]}


@app.post("/uploadfiles/")
async def create_upload_files(files: List[UploadFile]):

Registered: Sun Nov 03 07:19:11 UTC 2024

- Last Modified: Sat Mar 18 12:29:59 UTC 2023

- 861 bytes

- Viewed (0)

github.com/minio/minio

internal/logger/target/kafka/kafka_scram_client_contrib.go

// error if the server message is invalid.  Calling Step after a conversation
// completes is also an error.
func (x *XDGSCRAMClient) Step(challenge string) (response string, err error) {
	response, err = x.ClientConversation.Step(challenge)
	return
}

// Done returns true if the conversation is completed or has errored.
func (x *XDGSCRAMClient) Done() bool {
	return x.ClientConversation.Done()

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Thu Nov 09 04:04:01 UTC 2023

- 3.3K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/test/java/okhttp3/internal/http/ThreadInterruptTest.kt

    server.start()
    val call =
      client.newCall(
        Request.Builder()
          .url(server.url("/"))
          .build(),
      )
    val response = call.execute()
    interruptLater(500)
    val responseBody = response.body.byteStream()
    val buffer = ByteArray(1024)
    assertFailsWith<IOException> {
      while (responseBody.read(buffer) != -1) {
      }
    }
    responseBody.close()

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Mon Jan 08 01:13:22 UTC 2024

- 4.6K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/test/java/okhttp3/SessionReuseTest.kt

    server.enqueue(MockResponse(body = "abc1"))
    server.enqueue(MockResponse(body = "abc2"))

    val request = Request(server.url("/"))

    client.newCall(request).execute().use { response ->
      assertEquals(200, response.code)
    }

    client.connectionPool.evictAll()
    assertEquals(0, client.connectionPool.connectionCount())

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Sat Jan 20 10:30:28 UTC 2024

- 6K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs_src/request_files/tutorial003_an_py39.py

from typing import Annotated

from fastapi import FastAPI, File, UploadFile
from fastapi.responses import HTMLResponse

app = FastAPI()


@app.post("/files/")
async def create_files(
    files: Annotated[list[bytes], File(description="Multiple files as bytes")],
):
    return {"file_sizes": [len(file) for file in files]}


@app.post("/uploadfiles/")
async def create_upload_files(
    files: Annotated[

Registered: Sun Nov 03 07:19:11 UTC 2024

- Last Modified: Sat Mar 18 12:29:59 UTC 2023

- 952 bytes

- Viewed (0)

github.com/minio/minio

docs/extensions/s3zip/examples/boto3/main.py

    request.headers.add_header('x-minio-extract', 'true')
event_system = s3.meta.events
event_system.register_first('before-sign.s3.*', _add_header)

# List zip contents
response = s3.list_objects_v2(Bucket="your-bucket", Prefix="path/to/file.zip/")
print(response)

# Download data.csv stored in the zip file

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Wed Aug 04 21:15:45 UTC 2021

- 771 bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs_src/websockets/tutorial001.py

from fastapi import FastAPI, WebSocket
from fastapi.responses import HTMLResponse

app = FastAPI()

html = """
<!DOCTYPE html>
<html>
    <head>
        <title>Chat</title>
    </head>
    <body>
        <h1>WebSocket Chat</h1>
        <form action="" onsubmit="sendMessage(event)">
            <input type="text" id="messageText" autocomplete="off"/>
            <button>Send</button>
        </form>
        <ul id='messages'>

Registered: Sun Nov 03 07:19:11 UTC 2024

- Last Modified: Thu Mar 26 19:09:53 UTC 2020

- 1.4K bytes

- Viewed (0)

github.com/codelibs/fess-suggest

src/main/java/org/codelibs/fess/suggest/converter/AnalyzerConverter.java

            final AnalyzeAction.Response readingResponse = client.admin().indices()
                    .prepareAnalyze(analyzerSettings.getAnalyzerSettingsIndexName(), text)
                    .setAnalyzer(analyzerSettings.getReadingAnalyzerName(field, lang)).execute().actionGet(settings.getIndicesTimeout());

            final AnalyzeAction.Response termResponse =

Registered: Fri Nov 08 09:08:12 UTC 2024

- Last Modified: Sat Oct 12 00:10:39 UTC 2024

- 4.8K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/app/web/base/FessSearchAction.java

import org.codelibs.fess.util.ComponentUtil;
import org.dbflute.optional.OptionalThing;
import org.lastaflute.web.login.LoginManager;
import org.lastaflute.web.response.ActionResponse;
import org.lastaflute.web.response.HtmlResponse;
import org.lastaflute.web.response.next.HtmlNext;
import org.lastaflute.web.ruts.process.ActionRuntime;

import jakarta.annotation.Resource;
import jakarta.servlet.http.HttpServletRequest;

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Thu Feb 22 01:53:18 UTC 2024

- 10K bytes

- Viewed (0)

Search Options