Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 53 for on_message (0.11 sec)

  1. tensorflow/c/eager/parallel_device/parallel_device_remote_test.cc

      ASSERT_TRUE(TF_GetCode(status.get()) == TF_OK) << TF_Message(status.get());
    
      TensorHandlePtr value_one(FloatTensorHandle(3., status.get()));
      ASSERT_TRUE(TF_GetCode(status.get()) == TF_OK) << TF_Message(status.get());
      TensorHandlePtr value_two(FloatTensorHandle(-2., status.get()));
      ASSERT_TRUE(TF_GetCode(status.get()) == TF_OK) << TF_Message(status.get());
      std::array<TFE_TensorHandle*, 2> in_components{value_one.get(),
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Jul 10 07:18:05 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  2. 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)
  3. tensorflow/c/eager/c_api_test_util.cc

      TFE_Op* op = TFE_NewOp(ctx, "AddV2", status);
      CHECK_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
      TFE_OpAddInput(op, a, status);
      CHECK_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
      TFE_OpAddInput(op, b, status);
      CHECK_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
      TF_DeleteStatus(status);
      TFE_OpSetAttrType(op, "T", TFE_TensorHandleDataType(a));
    
      return op;
    }
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Feb 21 22:37:46 UTC 2024
    - 23.5K bytes
    - Viewed (0)
  4. tensorflow/c/eager/c_api_cluster_test.cc

      EXPECT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
    
      TFE_TensorHandle* retvals[1];
      int num_retvals = 1;
      TFE_Execute(matmul, &retvals[0], &num_retvals, status);
      EXPECT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
    
      auto* retval_task0 =
          TFE_TensorHandleCopyToDevice(retvals[0], ctx, local_device_name, status);
      ASSERT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  5. tensorflow/c/c_api_experimental_test.cc

      TF_Tensor* tensor_1X6 = Int32Tensor({1, 6});
      CHECK_EQ(TF_OK, TF_GetCode(status_)) << TF_Message(status_);
      TF_Tensor* tensor_1X1X6 = Int32Tensor({1, 1, 6});
      CHECK_EQ(TF_OK, TF_GetCode(status_)) << TF_Message(status_);
    
      TFE_Op* reshape_op = TFE_NewOp(tfe_context_, "Reshape", status_);
      CHECK_EQ(TF_OK, TF_GetCode(status_)) << TF_Message(status_);
      TFE_OpSetAttrType(reshape_op, "T", TF_FLOAT);
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Tue Jan 17 22:27:52 UTC 2023
    - 13.1K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/WebSocketListener.kt

        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,
      ) {
      }
    
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2K bytes
    - Viewed (0)
  7. samples/slack/src/main/java/okhttp3/slack/RtmSession.java

        System.out.println("onOpen: " + response);
      }
    
      // TOOD(jwilson): decode incoming messages and dispatch them somewhere.
      @Override public void onMessage(WebSocket webSocket, String text) {
        System.out.println("onMessage: " + text);
      }
    
      @Override public void onClosing(WebSocket webSocket, int code, String reason) {
        webSocket.close(1000, null);
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Nov 19 20:16:58 UTC 2016
    - 2.4K bytes
    - Viewed (0)
  8. tensorflow/c/eager/c_api_debug_test.cc

      TFE_Context* ctx = TFE_NewContext(opts, status);
      CHECK_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
      TFE_DeleteContextOptions(opts);
    
      TFE_TensorHandle* h = TestScalarTensorHandle(ctx, 1.0f);
      TFE_TensorDebugInfo* debug_info = TFE_TensorHandleTensorDebugInfo(h, status);
      CHECK_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
    
      ASSERT_EQ(0, TFE_TensorDebugInfoOnDeviceNumDims(debug_info));
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Apr 06 22:10:09 UTC 2020
    - 2.3K bytes
    - Viewed (0)
  9. tensorflow/c/eager/c_api_test.cc

        CHECK_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
        TFE_OpAddInput(matmul, m, status);
        CHECK_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
        TFE_OpAddInput(matmul, m, status);
        CHECK_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
        TFE_Execute(matmul, &retvals[0], &num_retvals, status);
        CHECK_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Aug 03 20:50:20 UTC 2023
    - 94.6K bytes
    - Viewed (0)
  10. 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)
Back to top