Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 53 for on_message (0.11 sec)

  1. docs/bucket/notifications/README.md

      # qos level is set to 1
      client.subscribe("minio", 1)
    
    def on_message(client, userdata, msg):
        print(msg.payload)
    
    # client_id is a randomly generated unique ID for the mqtt broker to identify the connection.
    client = mqtt.Client(client_id="myclientid",clean_session=False)
    
    client.on_connect = on_connect
    client.on_message = on_message
    
    client.connect("localhost",1883,60)
    client.loop_forever()
    ```
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 84K bytes
    - Viewed (0)
  2. tensorflow/c/eager/parallel_device/parallel_device_test.cc

      ASSERT_EQ(TF_GetCode(status.get()), TF_OK) << TF_Message(status.get());
      TFE_OpSetDevice(op.get(), device_name, status.get());
      ASSERT_EQ(TF_GetCode(status.get()), TF_OK) << TF_Message(status.get());
      TFE_OpAddInput(op.get(), parallel_value.get(), status.get());
      ASSERT_EQ(TF_GetCode(status.get()), TF_OK) << TF_Message(status.get());
    
      TFE_TensorHandle* raw_result_handle;
      int num_retvals = 1;
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Tue Aug 06 23:56:17 UTC 2024
    - 29.4K bytes
    - Viewed (0)
  3. tensorflow/c/eager/custom_device_test.cc

      ASSERT_TRUE(TF_GetCode(status.get()) == TF_OK) << TF_Message(status.get());
      bool arrived = false;
      bool executed = false;
      const char* name = "/job:localhost/replica:0/task:0/device:CUSTOM:0";
      RegisterLoggingDevice(context, name, /*strict_scope_placement=*/true,
                            &arrived, &executed, status.get());
      ASSERT_TRUE(TF_GetCode(status.get()) == TF_OK) << TF_Message(status.get());
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Aug 27 23:39:24 UTC 2020
    - 18.4K bytes
    - Viewed (0)
  4. tensorflow/c/eager/c_api_remote_test.cc

      ASSERT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
      auto* h1_task1 =
          TFE_TensorHandleCopyToDevice(h1_task0, ctx, remote_device_name, status);
      ASSERT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
    
      TFE_Op* matmul = MatMulOp(ctx, h0_task1, h1_task1);
      TFE_OpSetDevice(matmul, remote_device_name, status);
      EXPECT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
    
      TFE_TensorHandle* retvals[1];
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Aug 12 00:14:22 UTC 2020
    - 5.4K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/AutobahnTester.kt

              println("Executing test case $number/$count")
              startNanos.set(System.nanoTime())
            }
    
            override fun onMessage(
              webSocket: WebSocket,
              bytes: ByteString,
            ) {
              webSocket.send(bytes)
            }
    
            override fun onMessage(
              webSocket: WebSocket,
              text: String,
            ) {
              webSocket.send(text)
            }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  6. tensorflow/c/eager/c_api_remote_test_util.cc

                                  status);
        CHECK_EQ(TF_GetCode(status), TF_OK) << TF_Message(status);
    
        matmul = TFE_NewOp(ctx, "MatMulFunction", status);
        ASSERT_EQ(TF_GetCode(status), TF_OK) << TF_Message(status);
        TFE_OpAddInput(matmul, h0_task0, status);
        ASSERT_EQ(TF_GetCode(status), TF_OK) << TF_Message(status);
        TFE_OpAddInput(matmul, has_packed_input ? packed_handle : h1_task2, status);
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Fri Dec 11 22:56:03 UTC 2020
    - 9.1K bytes
    - Viewed (0)
  7. tensorflow/c/eager/parallel_device/parallel_device_lib_test.cc

      ASSERT_TRUE(TF_GetCode(status.get()) == TF_OK) << TF_Message(status.get());
      TFE_OpSetAttrType(handle_op.get(), "dtype", TF_FLOAT);
      TFE_OpSetAttrShape(handle_op.get(), "shape", /*dims=*/nullptr, /*num_dims=*/0,
                         status.get());
      ASSERT_TRUE(TF_GetCode(status.get()) == TF_OK) << TF_Message(status.get());
      auto outputs =
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Oct 21 04:14:14 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  8. tensorflow/c/eager/c_api_unified_experimental_test.cc

        ASSERT_EQ(TF_OK, TF_GetCode(s)) << TF_Message(s);
        TF_OutputListPushBack(func_outputs, add_output2, s);
        ASSERT_EQ(TF_OK, TF_GetCode(s)) << TF_Message(s);
        TF_OutputListPushBack(func_outputs, mm_output, s);
        ASSERT_EQ(TF_OK, TF_GetCode(s)) << TF_Message(s);
        func = TF_FinalizeFunction(graph_ctx, func_outputs, s);
        ASSERT_EQ(TF_OK, TF_GetCode(s)) << TF_Message(s);
        TF_DeleteOutputList(func_outputs);
      }
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 39.1K bytes
    - Viewed (0)
  9. compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/MojoFailureException.java

         *
         * @param source
         * @param shortMessage
         * @param longMessage
         */
        public MojoFailureException(Object source, String shortMessage, String longMessage) {
            super(shortMessage);
            this.source = source;
            this.longMessage = longMessage;
        }
    
        /**
         * Construct a new <code>MojoFailureException</code> exception providing a message.
         *
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/internal/ws/WebSocketRecorder.kt

        } else {
          events.add(Open(webSocket, response))
        }
      }
    
      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))
        }
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.9K bytes
    - Viewed (0)
Back to top