R test future stream_in

tmp.R

library(future)
library(jsonlite)

basicHander <- function(jsdata) {
	print(jsdata)
}

basicDisconnect <- function(a) {
	cat("Deberia llamar a connect_p")
	cat("....", a)
}

connect_p <- function(FUN, FUN2) {
	f <- future({
		stream_in(url("http://127.0.0.1:1337"), FUN, pagesize=1)

		"saliendo"
	}) %plan% multiprocess

	while(!resolved(f)) {
		Sys.sleep(2)
		cat("deberia comprobar el estado del heartbeat")
	}

	FUN2(value(f))

	"saliendo de esta conextion"
}