inst/example/index.R

In altairwei/rwebchannel: Qt QWebChannel client for R.

library(rwebchannel)
library(websocket)

start <- function() {
  cat("Enter: ")
  input <- readLines("stdin", 1)
  if (input == "exit")
    quit()
  if (input == "")
    return()
  send(input)
  later::later(start)
}

baseUrl <- "ws://localhost:12345"
cat(paste0("Connecting to WebSocket server at ", baseUrl, ".\n"))

socket <- WebSocket$new(baseUrl, autoConnect = FALSE)

socket$onClose(function(event) {
  cat("web channel closed\n\n")
})

socket$onError(function(event) {
  cat(paste0("web channel error:", event$message, "\n"))
})

socket$onOpen(function(event) {
  cat("WebSocket connected, setting up QWebChannel.\n")
  QWebChannel$new(socket, function(channel) {
    assign("core", channel$objects[["core"]], envir = .GlobalEnv)
    assign("send", function(text) {
      cat("Sent message: ", text, "\n")
      core$receiveText(text)
    }, envir = .GlobalEnv)
    core$sendText$connect(function(message) {
      cat("Received message: ", message, "\n")
      start()
    })
  })
})

socket$connect()

while (TRUE) {
  later::run_now()
}