Merge pull request #3 from meantrix/develop

Async 0.0.4

Author: igor-siciliani

CHANGELOG.md

@@ -1,5 +1,15 @@
 #CHANGELOG
 
+## Async 0.0.4
+
+- `async[R6]` : New param verbose to provides much more 
+information about the flow of information between the R processes. 
+
+### Bug Fixes :
+
+- Error: `"observer error: Error in if (private$interrupted()) {: argument is of length zero\n"`
+in async class fixed.
+
 ## Async 0.0.3
 
 New routines to save and load async objects as `rds` files ;
@@ -21,7 +31,7 @@ New progress bar with cancel button;
 - The package documentation has been rewritten.
 
 ### Bugs
-- `asyn: get_status` method  character(0) error fixed;
+- `async: get_status` method  character(0) error fixed;
 
 
 

DESCRIPTION

@@ -1,7 +1,7 @@
 Package: async
 Type: Package
 Title: Async
-Version: 0.0.3
+Version: 0.0.4
 Authors@R: 
     c(person(
       given = "Igor",

R/async.R

@@ -37,6 +37,7 @@ async = R6::R6Class(classname = 'async',
                     private = list(
 
                       vars = list(status_file = NULL,
+                                  verbose = FALSE,
                                   upper = 100,
                                   lower = 0,
                                   auto.finish = TRUE,
@@ -49,7 +50,11 @@ async = R6::R6Class(classname = 'async',
                         vm = scan(private$vars$status_file,
                                   what = "character",
                                   sep="\n",quiet = TRUE)
-                        print(vm)
+
+                        if(private$vars$verbose){
+                          message(paste0("get status: ",vm))
+                        }
+
                         vm = try(stringr::str_split(vm,' zzzz ')[[1]])
 
                         if(!inherits(vm,'try-error')){
@@ -65,15 +70,22 @@ async = R6::R6Class(classname = 'async',
                         vm = paste0(value,' zzzz ',msg ,' zzzz ',detail)
                         write(vm, private$vars$status_file)
 
+                        if(private$vars$verbose){
+                          message(paste0("set status: ",vm))
+                        }
+
                         vm.out = stringr::str_split(vm,' zzzz ')[[1]]
                         names(vm.out) = c('value','message','detail')
+
+
+
                         private$vars$vm = vm.out
 
 
                       },
 
                       interrupted = function(){
-                        private$get_status()[1] == "7777"
+                        isTRUE(private$get_status()[1] == "7777")
                       },
 
 
@@ -85,7 +97,7 @@ async = R6::R6Class(classname = 'async',
 
                         }
 
-                        if(private$get_status()[1] == as.character(private$vars$upper)
+                        if( isTRUE(private$get_status()[1] == as.character(private$vars$upper))
                            && private$vars$auto.finish) {
                           #unlink(private$vars$status_file)
                           stop("Process finished")
@@ -163,13 +175,16 @@ async = R6::R6Class(classname = 'async',
                       #'be interrupted when the progress is equal to the upper value.
                       #' @param reactive If its true generate a reactive expression
                       #' is a expression whose result will change over time.
+                      #' @param verbose logical.If its TRUE  provides much more
+                      #' information about the flow of information between the R processes.
                       #' @param msg A single-element character vector;
                       #' the initial message to be pass between processes.
                       #' @param detail A single-element character vector;
                       #' the initial detail message to be pass between processes.
                       initialize = function(lower, upper,
                                             auto.finish = TRUE,
                                             reactive=TRUE,
+                                            verbose = FALSE,
                                             msg,
                                             detail){
 
@@ -192,6 +207,7 @@ async = R6::R6Class(classname = 'async',
                         checkmate::expect_numeric(c(lower,upper),lower = 0,upper = 1000)
                         checkmate::expect_logical(auto.finish,max.len = 1)
                         checkmate::expect_logical(reactive,max.len = 1)
+                        checkmate::expect_logical(verbose,max.len = 1)
                         checkmate::expect_character(msg,max.len = 1)
                         checkmate::expect_character(detail,max.len = 1)
 
@@ -211,6 +227,7 @@ async = R6::R6Class(classname = 'async',
                         private$.reactive = reactive
                         private$rx_trigger =  reactiveTrigger()
 
+                        private$vars$verbose = verbose
                         private$vars$lower = lower
                         private$vars$upper = upper
                         private$vars$auto.finish = auto.finish
@@ -225,7 +242,10 @@ async = R6::R6Class(classname = 'async',
                       #' the interrupt detail message to be pass between processes.
                       interrupt = function(msg="process interrupted", detail =""){
 
-                        args = list(value = 7777, msg = msg, detail ='')
+                        checkmate::expect_character(msg,max.len = 1)
+                        checkmate::expect_character(detail,max.len = 1)
+
+                        args = list(value = 7777, msg = msg, detail =detail)
                         do.call(private$set_status, args = args)
 
                         if(isTRUE(private$.reactive)){

README.md

@@ -3,7 +3,7 @@
 ![logo](https://github.com/meantrix/async/blob/develop/inst/header_transparente_colorido.png)
 
 <!--- These are examples. See https://shields.io for others or to customize this set of shields. You might want to include dependencies, project status and licence info here --->
-[![version](https://img.shields.io/badge/version-0.0.3-green.svg)](https://semver.org)
+[![version](https://img.shields.io/badge/version-0.0.4-green.svg)](https://semver.org)
 
 
 async is a `tool` for passing messages between some R processes 

examples/progress_bar.R

@@ -18,7 +18,7 @@ server <- function(input, output,session) {
   N <- 100
   reactlog_enable()
   asy1 = async$new(reactive=TRUE,auto.finish=FALSE,lower = 0, upper = 100)
-  asy2 = async$new(reactive = TRUE,auto.finish = FALSE)
+  asy2 = async$new(reactive = TRUE,auto.finish = FALSE,verbose = T)