Merge pull request #7 from meantrix/develop

0.0.6

Author: igor-siciliani

CHANGELOG.md

@@ -1,5 +1,9 @@
 # CHANGELOG
 
+## Async 0.0.6
+
+- Fix `async$get_status` due to scan read error ;  
+
 ## Async 0.0.5
 
 - Fix `asyncBar2` behaviour where abortion notification was dismissed before the abortion was concluded. The `removeNotification` is now called on `finalize` method;

DESCRIPTION

@@ -1,7 +1,7 @@
 Package: async
 Type: Package
 Title: Async
-Version: 0.0.5
+Version: 0.0.6
 Authors@R: 
     c(person(
       given = "Igor",
@@ -23,4 +23,4 @@ Depends:
 License: MIT License 
 Encoding: UTF-8
 LazyData: true
-RoxygenNote: 7.1.1
+RoxygenNote: 7.2.1

R/async.R

@@ -47,22 +47,27 @@ async = R6::R6Class(classname = 'async',
                       .reactive =TRUE,
 
                       get_status = function(){
-                        vm = scan(private$vars$status_file,
+                        . = NULL
+                        vm = try(
+                                (scan(private$vars$status_file,
                                   what = "character",
-                                  sep="\n",quiet = TRUE)
-
-                        if(private$vars$verbose){
-                          message(paste0("get status: ",vm))
-                        }
-
-                        vm = try(stringr::str_split(vm,' zzzz ')[[1]])
+                                  sep="\n",quiet = TRUE) %>%
+                                  stringr::str_split(.,' zzzz '))[[1]] ,
+                                  silent = TRUE
+                             )
 
                         if(!inherits(vm,'try-error')){
+                          if(private$vars$verbose) message(paste0("get status: ",vm))
                           names(vm) = c('value','message','detail')
                           private$vars$vm = vm
                           return(vm)
                         }
 
+                        if(private$vars$verbose){
+                          message("Async: cant open tempfile: ", private$vars$status_file)
+                        }
+                        NULL
+
                       },
 
                       set_status = function(value, msg = "",detail=""){
@@ -77,8 +82,6 @@ async = R6::R6Class(classname = 'async',
                         vm.out = stringr::str_split(vm,' zzzz ')[[1]]
                         names(vm.out) = c('value','message','detail')
 
-
-
                         private$vars$vm = vm.out
 
 

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.5-green.svg)](https://semver.org)
+[![version](https://img.shields.io/badge/version-0.0.6-green.svg)](https://semver.org)
 
 
 async is a `tool` for passing messages between some R processes