Response_ - Code Search

istioctl/pkg/xds/client.go

	err = adscConn.Run()
	if err != nil {
		return nil, fmt.Errorf("ADSC: failed running %v", err)
	}

	err = adscConn.Send(dr)
	if err != nil {
		return nil, err
	}
	response, err := adscConn.WaitVersion(opts.Timeout, dr.TypeUrl, "")
	return response, err
}

// DialOptions constructs gRPC dial options from command line configuration
func DialOptions(opts clioptions.CentralControlPlaneOptions,

Registered: Wed Nov 06 22:53:10 UTC 2024

- Last Modified: Tue Dec 19 22:42:42 UTC 2023

- 3.7K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/smb1/SmbTree.java

    }
    void send( ServerMessageBlock request,
                            ServerMessageBlock response ) throws SmbException {
synchronized (session.transport()) {
        if( response != null ) {
            response.received = false;
        }
        treeConnect( request, response );
        if( request == null || (response != null && response.received )) {
            return;
        }
        if( service.equals( "A:" ) == false ) {

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

- Last Modified: Fri Mar 22 21:10:40 UTC 2019

- 8K bytes

- Viewed (0)

github.com/tiangolo/fastapi

tests/test_tutorial/test_websockets/test_tutorial003_py39.py


@pytest.fixture(name="client")
def get_client(app: FastAPI):
    client = TestClient(app)

    return client


@needs_py39
def test_get(client: TestClient, html: str):
    response = client.get("/")
    assert response.text == html


@needs_py39
def test_websocket_handle_disconnection(client: TestClient):
    with client.websocket_connect("/ws/1234") as connection, client.websocket_connect(
        "/ws/5678"

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

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

- 1.3K bytes

- Viewed (0)

github.com/minio/minio

cmd/bucket-listobjects-handlers.go

		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
		return
	}
	response := generateListVersionsResponse(ctx, bucket, prefix, marker, versionIDMarker, delimiter, encodingType, maxkeys, listObjectVersionsInfo, checkObjMeta)

	// Write success response.
	writeSuccessResponseXML(w, encodeResponseList(response))
}

// ListObjectsV2MHandler - GET Bucket (List Objects) Version 2 with metadata.

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

- Last Modified: Tue Jun 11 03:13:30 UTC 2024

- 11.4K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/internal/SmbNegotiation.java

        this.response = response;
        this.negoReqBuffer = negoReqBuffer;
        this.negoRespBuffer = negoRespBuffer;
    }


    /**
     * @return the request
     */
    public SmbNegotiationRequest getRequest () {
        return this.request;
    }


    /**
     * @return the response
     */
    public SmbNegotiationResponse getResponse () {
        return this.response;
    }

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

- Last Modified: Sun Jul 01 13:12:10 UTC 2018

- 2K bytes

- Viewed (0)

github.com/square/okhttp

okhttp-testing-support/src/main/kotlin/okhttp3/ClientRuleEventListener.kt

  override fun satisfactionFailure(
    call: Call,
    response: Response,
  ) {
    logWithTime("satisfactionFailure")

    delegate.satisfactionFailure(call, response)
  }

  override fun cacheMiss(call: Call) {
    logWithTime("cacheMiss")

    delegate.cacheMiss(call)
  }

  override fun cacheHit(
    call: Call,
    response: Response,
  ) {
    logWithTime("cacheHit")

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

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

- 6K bytes

- Viewed (0)

github.com/tiangolo/fastapi

tests/test_tutorial/test_response_headers/test_tutorial002.py

from docs_src.response_headers.tutorial002 import app

client = TestClient(app)


def test_path_operation():
    response = client.get("/headers-and-object/")
    assert response.status_code == 200, response.text
    assert response.json() == {"message": "Hello World"}

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

- Last Modified: Thu Jul 09 18:06:12 UTC 2020

- 378 bytes

- Viewed (0)

github.com/square/okhttp

okhttp-logging-interceptor/README.md

Logging Interceptor
===================

An [OkHttp interceptor][interceptors] which logs HTTP request and response data.

```java
HttpLoggingInterceptor logging = new HttpLoggingInterceptor();
logging.setLevel(Level.BASIC);
OkHttpClient client = new OkHttpClient.Builder()
  .addInterceptor(logging)
  .build();
```

You can change the log level at any time by calling `setLevel()`.

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

- Last Modified: Sun Dec 17 15:34:10 UTC 2023

- 1.3K bytes

- Viewed (0)

github.com/square/okhttp

samples/guide/src/main/java/okhttp3/recipes/AsynchronousGet.java

        e.printStackTrace();
      }

      @Override public void onResponse(Call call, Response response) throws IOException {
        try (ResponseBody responseBody = response.body()) {
          if (!response.isSuccessful()) throw new IOException("Unexpected code " + response);

          Headers responseHeaders = response.headers();
          for (int i = 0, size = responseHeaders.size(); i < size; i++) {

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

- Last Modified: Sun May 22 01:29:42 UTC 2016

- 1.9K bytes

- Viewed (0)

github.com/tiangolo/fastapi

tests/test_tutorial/test_websockets/test_tutorial002_an.py

from fastapi.websockets import WebSocketDisconnect

from docs_src.websockets.tutorial002_an import app


def test_main():
    client = TestClient(app)
    response = client.get("/")
    assert response.status_code == 200, response.text
    assert b"<!DOCTYPE html>" in response.content


def test_websocket_with_cookie():
    client = TestClient(app, cookies={"session": "fakesession"})
    with pytest.raises(WebSocketDisconnect):

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

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

- 3.6K bytes

- Viewed (0)

Search Options