mymessage - Code Search

guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedInputs.java

      super(message);
    }

    public ExceptionWithManyConstructorsButOnlyOneThrowable(
        String message, String a1, String a2, String a3) {
      super(message);
    }

    public ExceptionWithManyConstructorsButOnlyOneThrowable(String message, Throwable antecedent) {
      super(message);
      this.antecedent = antecedent;
    }

    public ExceptionWithManyConstructorsButOnlyOneThrowable(

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 16 15:59:55 GMT 2026

- 6.3K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedInputs.java

      super(message);
    }

    public ExceptionWithManyConstructorsButOnlyOneThrowable(
        String message, String a1, String a2, String a3) {
      super(message);
    }

    public ExceptionWithManyConstructorsButOnlyOneThrowable(String message, Throwable antecedent) {
      super(message);
      this.antecedent = antecedent;
    }

    public ExceptionWithManyConstructorsButOnlyOneThrowable(

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 16 15:59:55 GMT 2026

- 6.3K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/util/transport/Message.java

 * Provides common functionality for message handling and processing.
 *
 * @author mbechler
 */
public interface Message {

    /**
     * Indicate that this message should retain it's raw payload
     */
    void retainPayload();

    /**
     * Determines whether to retain the message payload.
     *
     * @return whether to retain the message payload
     */
    boolean isRetainPayload();

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

- Last Modified: Sat Aug 16 01:32:48 GMT 2025

- 1.6K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketRecorder.kt

    }
  }

  override fun onMessage(
    webSocket: WebSocket,
    bytes: ByteString,
  ) {
    Platform.get().log("[WS $name] onMessage", Platform.INFO, null)
    val delegate = delegate
    if (delegate != null) {
      this.delegate = null
      delegate.onMessage(webSocket, bytes)
    } else {
      events.add(Message(bytes = bytes))
    }
  }

  override fun onMessage(

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Tue Feb 03 22:17:59 GMT 2026

- 6.8K bytes

- Click Count (0)

github.com/minio/minio

cmd/server-startup-msg.go

		logger.Startup(color.Blue("\nCLI: ") + mcQuickStartGuide)
		mcMessage := fmt.Sprintf("$ mc alias set '%s' '%s' '%s' '%s'", alias,
			endPoint, cred.AccessKey, cred.SecretKey)
		logger.Startup(fmt.Sprintf(getFormatStr(len(mcMessage), 3), mcMessage))
	}

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

- Last Modified: Tue Aug 12 18:20:36 GMT 2025

- 6.2K bytes

- Click Count (0)

github.com/square/okhttp

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

    webSocket.close(1000, "Goodbye, World!");
  }

  @Override public void onMessage(WebSocket webSocket, String text) {
    System.out.println("MESSAGE: " + text);
  }

  @Override public void onMessage(WebSocket webSocket, ByteString bytes) {
    System.out.println("MESSAGE: " + bytes.hex());
  }

  @Override public void onClosing(WebSocket webSocket, int code, String reason) {

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Thu Apr 04 11:40:21 GMT 2024

- 1.6K bytes

- Click Count (0)

github.com/square/okhttp

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

    webSocket: WebSocket,
    response: Response,
  ) {
  }

  /** Invoked when a text (type `0x1`) message has been received. */
  open fun onMessage(
    webSocket: WebSocket,
    text: String,
  ) {
  }

  /** Invoked when a binary (type `0x2`) message has been received. */
  open fun onMessage(
    webSocket: WebSocket,
    bytes: ByteString,
  ) {
  }

  /**

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Fri Dec 27 13:39:56 GMT 2024

- 2K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs_src/websockets_/tutorial003_py310.py

            ws.onmessage = function(event) {
                var messages = document.getElementById('messages')
                var message = document.createElement('li')
                var content = document.createTextNode(event.data)
                message.appendChild(content)
                messages.appendChild(message)
            };
            function sendMessage(event) {

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

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

- 2.5K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs_src/websockets_/tutorial002_an_py310.py

                ws.onmessage = function(event) {
                    var messages = document.getElementById('messages')
                    var message = document.createElement('li')
                    var content = document.createTextNode(event.data)
                    message.appendChild(content)
                    messages.appendChild(message)
                };
                event.preventDefault()

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

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

- 2.8K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs_src/websockets_/tutorial002_py310.py

                ws.onmessage = function(event) {
                    var messages = document.getElementById('messages')
                    var message = document.createElement('li')
                    var content = document.createTextNode(event.data)
                    message.appendChild(content)
                    messages.appendChild(message)
                };
                event.preventDefault()

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

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

- 2.7K bytes

- Click Count (0)

Search Options