consent - Code Search

build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/JavadocScanner.java

import java.io.BufferedReader;
import java.io.IOException;
import java.io.StringReader;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

/**
 * Extracts the main description of a javadoc comment from its raw text, as a stream of characters. See
 * http://download.oracle.com/javase/1.5.0/docs/tooldocs/solaris/javadoc.html#documentationcomments for details.
 *
 * <ul>
 * <li>Removes leading '*' characters.</li>

Registered: Wed Dec 31 11:36:14 UTC 2025

- Last Modified: Wed Dec 09 08:14:05 UTC 2020

- 4.3K bytes

- Viewed (0)

github.com/minio/minio

internal/grid/benchmark_test.go

	}
	grid, err := SetupTestGrid(n)
	errFatal(err)
	b.Cleanup(grid.Cleanup)
	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 {

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Fri Aug 29 02:39:48 UTC 2025

- 15.5K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/app/web/profile/ProfileAction.java

        super();
    }

    private static final Logger logger = LogManager.getLogger(ProfileAction.class);

    // ===================================================================================
    // Constant
    //

    // ===================================================================================
    // Attribute
    //
    @Resource
    private UserService userService;

Registered: Sat Dec 20 09:19:18 UTC 2025

- Last Modified: Thu Nov 27 07:01:25 UTC 2025

- 4.5K bytes

- Viewed (0)

github.com/square/okhttp

okhttp-sse/src/main/kotlin/okhttp3/sse/EventSource.kt

   */
  fun cancel()

  fun interface Factory {
    /**
     * Creates a new event source and immediately returns it. Creating an event source initiates an
     * asynchronous process to connect the socket. Once that succeeds or fails, `listener` will be
     * notified. The caller must cancel the returned event source when it is no longer in use.
     */
    fun newEventSource(
      request: Request,

Registered: Fri Dec 26 11:42:13 UTC 2025

- Last Modified: Fri Oct 03 07:51:20 UTC 2025

- 1.4K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/app/web/error/ErrorNotfoundAction.java

        super();
    }

    // ===================================================================================
    //                                                                            Constant
    //

    // ===================================================================================
    //                                                                           Attribute
    //

Registered: Sat Dec 20 09:19:18 UTC 2025

- Last Modified: Thu Jul 17 08:28:31 UTC 2025

- 2.1K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/app/web/admin/joblog/EditForm.java

     */
    @Required
    public String scriptType;

    /**
     * The script data or code that was executed.
     * This field contains the actual script content that was run.
     */
    public String scriptData;

    /**
     * The result or output from the script execution.
     * This field contains any output or result data from the script.
     */

Registered: Sat Dec 20 09:19:18 UTC 2025

- Last Modified: Thu Jul 17 08:28:31 UTC 2025

- 3.3K bytes

- Viewed (0)

github.com/tiangolo/fastapi

tests/test_tutorial/test_websockets/test_tutorial002.py

    return mod.app


def test_main(app: FastAPI):
    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(app: FastAPI):
    client = TestClient(app, cookies={"session": "fakesession"})
    with pytest.raises(WebSocketDisconnect):

Registered: Sun Dec 28 07:19:09 UTC 2025

- Last Modified: Wed Dec 17 20:41:43 UTC 2025

- 4.1K bytes

- Viewed (0)

github.com/gradle/gradle

build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/ClassDocMethodsBuilder.java

                MethodDoc methodDoc = new MethodDoc(method, docComment.getDocbook());
                if (methodDoc.getDescription() == null) {
                    throw new RuntimeException(String.format("Docbook content for '%s %s' does not contain a description paragraph.", classDoc.getName(), method.getSignature()));
                }
                PropertyDoc property = classDoc.findProperty(methodName);

Registered: Wed Dec 31 11:36:14 UTC 2025

- Last Modified: Wed Dec 09 08:14:05 UTC 2020

- 4.2K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs/es/docs/advanced/websockets.md

Ahí puedes establecer:

* El "ID del Ítem", usado en el path.
* El "Token" usado como un parámetro query.

/// tip | Consejo

Nota que el query `token` será manejado por una dependencia.

///

Con eso puedes conectar el WebSocket y luego enviar y recibir mensajes:

<img src="/img/tutorial/websockets/image05.png">

Registered: Sun Dec 28 07:19:09 UTC 2025

- Last Modified: Wed Dec 17 20:41:43 UTC 2025

- 5.9K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt

 *    * dispatcher queue ([dispatcherQueueStart], [dispatcherQueueEnd])
 *    * proxy selection ([proxySelectStart], [proxySelectEnd])
 *    * dns ([dnsStart], [dnsEnd])
 *    * connect ([connectStart], [connectEnd], [connectFailed])
 *      * secure connect ([secureConnectStart], [secureConnectEnd])
 *    * connection held ([connectionAcquired], [connectionReleased])
 *      * request ([requestFailed])

Registered: Fri Dec 26 11:42:13 UTC 2025

- Last Modified: Tue Oct 07 21:03:04 UTC 2025

- 24.9K bytes

- Viewed (0)

Search Options