R/bolt.R

In RStorm: Simulate and Develop Streaming Processing

Defines functions Bolt is.Bolt

Documented in Bolt is.Bolt

Bolt <- function(FUNC, listen=0, boltID=0){
	x <- list()
	if(!is.function(FUNC)){
		stop("Please provide a processing function")
	}
	x$name <- as.character(substitute(FUNC))
	x$func <- FUNC
	x$listen <- listen
	x$id <- boltID
	class(x) <- "Bolt"
	x
}

# Check, internal function
is.Bolt <- function(x){
	ifelse( class(x) == "Bolt", TRUE, FALSE)
}

Try the RStorm package in your browser