R/queue-txtq.R

In dipsaus: A Dipping Sauce for Data Analysis and Visualizations

# TextQueue <- R6::R6Class(
#   classname = 'TextQueue',
#   inherit = AbstractQueue,
#   private = list(
#     txtq = NULL,
#     txtq_private = NULL
#   ),
#   public = list(
#     # Get head so that we know where we are in the queue
#     `@get_head` = function() {
#       # Have to do this, they didn't expose head
#       private$txtq_private$txtq_get_head()
#     },
#     `@set_head` = function(v) {
#       private$txtq_private$txtq_set_head(v)
#     },
#
#     # Get total number of items in the queue
#     `@get_total` = function() {
#       private$txtq_private$txtq_get_total()
#     },
#     `@set_total` = function(v) {
#       private$txtq_private$txtq_set_total(v)
#     },
#
#     `@inc_total` = function(n=1) {
#       private$txtq_private$txtq_inc_total(n=n)
#     },
#
#     `@append_header` = function(msg, ...) {
#       private$txtq$push(title = 'header', message = msg)
#       return(0)
#     },
#
#     `@store_value` = function(value, key) {
#       s <- ''
#       con <- textConnection('s', 'w', local = TRUE)
#       serialize(value, connection = con)
#       close(con)
#       s <- paste(s, collapse = '\n')
#       s
#     },
#     restore_value = function(hash, key, preserve = FALSE) {
#       con <- textConnection(hash, 'r', local = TRUE)
#       re <- tryCatch({
#         unserialize(connection = con)
#       }, error = function(e) {
#         NULL
#       })
#       re
#     },
#
#     `@log` = function(n = -1, all = FALSE) {
#       if ( all ) { head <- 0 } else { head <- self$head }
#       total <- self$total
#       count <- total - head
#       if ( n <= 0 ) { n <- count } else { n <- min(n, count) }
#       if ( n == 0 ) { return() }
#       if ( all ) {
#         tbl <- private$txtq$log()
#       } else {
#         tbl <- private$txtq$list(n = n)
#       }
#       stringr::str_split_fixed(tbl$message, '\\|', 4)
#     },
#
#     `@reset` = function() {
#       private$txtq$reset()
#     },
#
#     `@clean` = function(preserve = FALSE, ...) {
#       private$txtq$clean()
#     },
#     `@validate` = function() {
#       private$txtq$validate()
#     },
#
#     `@connect` = function(path) {
#
#     },
#
#     initialize = function(path = tempfile()) {
#       if (requireNamespace('txtq'))
#       private$txtq <- txtq::txtq(path)
#       private$txtq_private <- private$txtq$.__enclos_env__$private
#     },
#
#     destroy = function() {
#       private$txtq$destroy()
#       delayedAssign('.lockfile', {cat2('Queue destroyed', level = 'FATAL')},
#                     assign.env = private)
#       delayedAssign('txtq', {cat2('Queue destroyed', level = 'FATAL')},
#                     assign.env = private)
#       delayedAssign('txtq_private', {cat2('Queue destroyed', level = 'FATAL')},
#                     assign.env = private)
#       invisible()
#     }
#   )
# )