Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 1,627 for message (0.14 sec)

  1. 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) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 04 11:40:21 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt

        }
    
        try {
          if (pong != null) {
            writer!!.writePong(pong)
          } else if (messageOrClose is Message) {
            val message = messageOrClose as Message
            writer!!.writeMessageFrame(message.formatOpcode, message.data)
            synchronized(this) {
              queueSize -= message.data.size.toLong()
            }
          } else if (messageOrClose is Close) {
            val close = messageOrClose as Close
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  3. compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/MojoFailureException.java

         *
         * @param message
         */
        public MojoFailureException(String message) {
            super(message);
        }
    
        /**
         * Construct a new <code>MojoFailureException</code> exception wrapping an underlying <code>Throwable</code>
         * and providing a <code>message</code>.
         *
         * @param message
         * @param cause
         * @since 2.0.9
         */
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/UncheckedExecutionException.java

      protected UncheckedExecutionException(@CheckForNull String message) {
        super(message);
      }
    
      /**
       * Creates a new instance with the given detail message and cause. Prefer to provide a
       * non-nullable {@code cause}, as many users expect to find one.
       */
      public UncheckedExecutionException(@CheckForNull String message, @CheckForNull Throwable cause) {
        super(message, cause);
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Mar 07 17:52:19 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt

      @JvmName("-deprecated_dispatcher")
      @Deprecated(
        message = "moved to val",
        replaceWith = ReplaceWith(expression = "dispatcher"),
        level = DeprecationLevel.ERROR,
      )
      fun dispatcher(): Dispatcher = dispatcher
    
      @JvmName("-deprecated_connectionPool")
      @Deprecated(
        message = "moved to val",
        replaceWith = ReplaceWith(expression = "connectionPool"),
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:21:33 UTC 2024
    - 52K bytes
    - Viewed (0)
  6. tests/test_tutorial/test_generate_clients/test_tutorial003.py

                        },
                    },
                    "ResponseMessage": {
                        "title": "ResponseMessage",
                        "required": ["message"],
                        "type": "object",
                        "properties": {"message": {"title": "Message", "type": "string"}},
                    },
                    "User": {
                        "title": "User",
                        "required": ["username", "email"],
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri Jun 30 18:25:16 UTC 2023
    - 7.1K bytes
    - Viewed (0)
  7. internal/s3select/genmessage.go

    	binary.Write(buf, binary.BigEndian, crc32.ChecksumIEEE(prelude))
    	buf.Write(header)
    	message := buf.Bytes()
    	binary.Write(buf, binary.BigEndian, crc32.ChecksumIEEE(message))
    
    	fmt.Println(buf.Bytes())
    }
    
    func genProgressHeader() {
    	buf := new(bytes.Buffer)
    
    	buf.WriteByte(13)
    	buf.WriteString(":message-type")
    	buf.WriteByte(7)
    	buf.Write([]byte{0, 5})
    	buf.WriteString("event")
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 19 01:35:22 UTC 2021
    - 4.4K bytes
    - Viewed (0)
  8. common-protos/k8s.io/api/rbac/v1/generated.proto

    }
    
    // ClusterRoleBindingList is a collection of ClusterRoleBindings
    message ClusterRoleBindingList {
      // Standard object's metadata.
      // +optional
      optional k8s.io.apimachinery.pkg.apis.meta.v1.ListMeta metadata = 1;
    
      // Items is a list of ClusterRoleBindings
      repeated ClusterRoleBinding items = 2;
    }
    
    // ClusterRoleList is a collection of ClusterRoles
    message ClusterRoleList {
      // Standard object's metadata.
      // +optional
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  9. common-protos/k8s.io/api/discovery/v1beta1/generated.proto

    // EndpointHints provides hints describing how an endpoint should be consumed.
    message EndpointHints {
      // forZones indicates the zone(s) this endpoint should be consumed by to
      // enable topology aware routing. May contain a maximum of 8 entries.
      // +listType=atomic
      repeated ForZone forZones = 1;
    }
    
    // EndpointPort represents a Port used by an EndpointSlice
    message EndpointPort {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 8K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

        if (localInputFuture != null) {
          String message = "inputFuture=[" + localInputFuture + "]";
          if (localTimer != null) {
            long delay = localTimer.getDelay(MILLISECONDS);
            // Negative delays look confusing in an error message
            if (delay > 0) {
              message += ", remaining delay=[" + delay + " ms]";
            }
          }
          return message;
        }
        return null;
      }
    
      @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 8.1K bytes
    - Viewed (0)
Back to top