## ----setup, include=FALSE-----------------------------------------------------
knitr::opts_chunk$set(echo = TRUE, comment = "#>")

## ----install, eval=FALSE------------------------------------------------------
# install.packages("streamConnect")

## ----load---------------------------------------------------------------------
library(streamConnect)

## ----no_localhost_guard, include=FALSE----------------------------------------
# skip the examples when localhost is unavailable
localhost_available <- has_localhost_server(port = 8000)
if (!localhost_available) {
  message("localhost not available, example skipped.")
}

## ----socket-publish, eval=localhost_available---------------------------------
port <- httpuv::randomPort()

socket_process <- publish_DSD_via_Socket(
  DSD_Gaussians(k = 3, d = 2),
  port = port
)
socket_process

## ----socket-read, eval=localhost_available------------------------------------
socket_dsd <- DSD_ReadSocket(
  port = port,
  col.names = c("x", "y", ".class")
)

points <- get_points(socket_dsd, n = 10)
head(points)

## ----socket-stop, eval=localhost_available------------------------------------
close_stream(socket_dsd)
if (socket_process$is_alive()) socket_process$kill()

## ----webservice-start, eval=localhost_available-------------------------------
web_port <- httpuv::randomPort()

clusterer_process <- publish_DSC_via_WebService(
  "DSC_DBSTREAM(r = .05)",
  port = web_port
)

clusterer <- DSC_WebService(paste0("http://localhost:", web_port))
clusterer

## ----webservice-update, eval=localhost_available------------------------------
stream <- DSD_Gaussians(k = 3, d = 2, noise = 0.05)
update(clusterer, stream, n = 500)

get_centers(clusterer)
get_weights(clusterer)

## ----webservice-stop, eval=localhost_available--------------------------------
if (clusterer_process$is_alive()) clusterer_process$kill()

## ----webservice-stream, eval=localhost_available------------------------------
port <- httpuv::randomPort()

source_process <- publish_DSD_via_WebService(
  "DSD_Gaussians(k = 3, d = 2)",
  port = port
)

remote_stream <- DSD_ReadWebService(paste0("http://localhost:", port))
get_points(remote_stream, n = 10)

## ----webservice-stream2, eval=localhost_available-----------------------------
if (source_process$is_alive()) source_process$kill()