Send - Code Search

doc/go_mem.html

<h3 id="chan">Channel communication</h3>

<p>
Channel communication is the main method of synchronization
between goroutines.  Each send on a particular channel
is matched to a corresponding receive from that channel,
usually in a different goroutine.
</p>

<p class="rule">
A send on a channel is synchronized before the completion of the
corresponding receive from that channel.
</p>

<p>
This program:
</p>

Created: Tue Apr 07 11:13:11 GMT 2026

- Last Modified: Tue Aug 05 15:41:37 GMT 2025

- 26.6K bytes

- Click Count (0)

github.com/codelibs/jcifs

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

    @Override
    public boolean equals(final Object obj) {
        if (obj instanceof final SmbTree tree) {
            return matches(tree.share, tree.service);
        }
        return false;
    }

    void send(final ServerMessageBlock request, final ServerMessageBlock response) throws SmbException {
        synchronized (session.transport()) {
            if (response != null) {
                response.received = false;
            }

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Thu Aug 14 07:14:38 GMT 2025

- 8.1K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs_src/websockets_/tutorial001_py310.py

    </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'>
        </ul>
        <script>
            var ws = new WebSocket("ws://localhost:8000/ws");
            ws.onmessage = function(event) {

Created: Sun Apr 05 07:19:11 GMT 2026

- Last Modified: Fri Feb 27 12:34:37 GMT 2026

- 1.4K bytes

- Click Count (0)

github.com/minio/minio

internal/event/target/webhook.go

		return err
	}
	if err := target.init(); err != nil {
		return err
	}
	err := target.send(eventData)
	if err != nil {
		if xnet.IsNetworkOrHostDown(err, false) {
			return store.ErrNotConnected
		}
	}
	return err
}

// send - sends an event to the webhook.
func (target *WebhookTarget) send(eventData event.Event) error {
	objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
	if err != nil {

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Fri Sep 06 23:06:30 GMT 2024

- 8.8K bytes

- Click Count (0)

github.com/minio/minio

cmd/listen-notification-handlers.go

	// Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers.
	// Use buffered channel to take care of burst sends or slow w.Write()
	mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames()))
	localCh := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity())

	// Convert local messages to JSON and send to mergeCh
	go func() {

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Tue Feb 18 16:25:55 GMT 2025

- 6K bytes

- Click Count (0)

github.com/elastic/elasticsearch

.github/ISSUE_TEMPLATE/bug.md

check your OS is [supported](https://www.elastic.co/support/matrix#show_os).
If it is not, the issue is likely to be closed.

For security vulnerabilities please only send reports to ******@****.***.
See https://www.elastic.co/community/security for more information.

Please fill in the following details to help us reproduce the bug:
-->

Created: Wed Apr 08 16:19:15 GMT 2026

- Last Modified: Thu May 07 00:50:18 GMT 2020

- 1.3K bytes

- Click Count (0)

github.com/codelibs/curl4j

src/main/java/org/codelibs/curl/Curl.java

     */
    protected Curl() {
        // nothing
    }

    /**
     * Creates a new CurlRequest with the HTTP GET method for the specified URL.
     *
     * @param url the URL to send the GET request to
     * @return a CurlRequest object configured with the GET method and the specified URL
     */
    public static CurlRequest get(final String url) {
        return new CurlRequest(Method.GET, url);
    }

Created: Thu Apr 02 15:34:12 GMT 2026

- Last Modified: Thu Nov 20 13:34:13 GMT 2025

- 5.9K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/test/java/jcifs/internal/witness/MockWitnessService.java

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * Mock witness service for integration testing.
 * Simulates a basic witness service that can accept registrations
 * and send notifications.
 */
public class MockWitnessService implements AutoCloseable {
    private static final Logger log = LoggerFactory.getLogger(MockWitnessService.class);

    private ServerSocket serverSocket;

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Sat Aug 23 09:06:40 GMT 2025

- 8.2K bytes

- Click Count (0)

github.com/minio/minio

internal/logger/help.go

			Optional:    true,
			Type:        "string",
			Sensitive:   true,
		},
		config.HelpKV{
			Key:         BatchSize,
			Description: "Number of events per HTTP send to webhook target",
			Optional:    true,
			Type:        "number",
		},
		config.HelpKV{
			Key:         QueueSize,
			Description: "configure channel queue size for webhook targets",
			Optional:    true,

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Wed Sep 11 22:20:42 GMT 2024

- 7.4K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs_src/openapi_webhooks/tutorial001_py310.py

    username: str
    monthly_fee: float
    start_date: datetime


@app.webhooks.post("new-subscription")
def new_subscription(body: Subscription):
    """
    When a new user subscribes to your service we'll send you a POST request with this
    data to the URL that you register for the event `new-subscription` in the dashboard.
    """


@app.get("/users/")
def read_users():

Created: Sun Apr 05 07:19:11 GMT 2026

- Last Modified: Thu Feb 12 13:19:43 GMT 2026

- 550 bytes

- Click Count (0)

Search Options