R/imports.R

In cardcorp/kineRic: Amazon Kinesis Consumer Application for Stream Processing

#' An R Kinesis Consumer
#'
#' This is a placeholder for storing import directives, please find more details in the \code{README.md} file.
#' @docType package
#' @importFrom futile.logger flog.trace flog.debug flog.info flog.appender appender.file flog.layout
#' @importFrom jsonlite fromJSON toJSON base64_dec base64_enc unbox
#' @importFrom rJava .jnew J .jbyte
#' @importFrom utils assignInMyNamespace
#' @name kineRic-package
NULL

## init for future update in below .onLoad hook
stdincon <- NULL

.onLoad <- function(libname, pkgname) {

    ## load Java classes
    rJava::.jpackage(pkgname, lib.loc = libname,
                     morePaths = list.files(system.file('inst/java', package = pkgname), full.names = TRUE))

    ## load stdin only once per R session to avoid the memory leak with
    ## always re-opening the connection
    assignInMyNamespace('stdincon',
                        suppressWarnings(file('stdin', open = 'r', blocking = TRUE)))

}