@@ -39,13 +39,13 @@ datashield.sessions <- function(conns, async=TRUE, success=NULL, error=NULL, err
3939 }
4040
4141 sessions <- list ()
42- async <- lapply(fconns , function (conn ) { ifelse(async , dsIsAsync(conn )$ session , FALSE ) })
42+ asyncs <- lapply(fconns , function (conn ) { ifelse(async , dsIsAsync(conn )$ session , FALSE ) })
4343 pb <- .newProgress(total = 1 + length(fconns ))
4444 # async first
4545 for (n in names(fconns )) {
46- if (async [[n ]]) {
46+ if (asyncs [[n ]]) {
4747 tryCatch({
48- sessions [[n ]] <- dsSession(fconns [[n ]], async = TRUE )
48+ sessions [[n ]] <- dsSession(fconns [[n ]], async = async )
4949 }, error = function (e ) {
5050 .appendError(n , conditionMessage(e ))
5151 if (.is.callback(error )) {
@@ -56,7 +56,7 @@ datashield.sessions <- function(conns, async=TRUE, success=NULL, error=NULL, err
5656 }
5757 # not async (blocking calls)
5858 for (n in names(fconns )) {
59- if (! async [[n ]]) {
59+ if (! asyncs [[n ]]) {
6060 tryCatch({
6161 .tickProgress(pb , tokens = list (what = paste0(" Session " , fconns [[n ]]@ name )))
6262 sessions [[n ]] <- dsSession(fconns [[n ]], async = FALSE )
@@ -80,14 +80,13 @@ datashield.sessions <- function(conns, async=TRUE, success=NULL, error=NULL, err
8080 tryCatch({
8181 msg <- paste0(fconns [[n ]]@ name , " : " , dsStateMessage(sessions [[n ]]))
8282 messages <- append(messages , msg )
83- if (async [[n ]]) {
83+ if (asyncs [[n ]]) {
8484 completed [[n ]] <- dsIsReady(sessions [[n ]])
8585 if (completed [[n ]]) {
86- .tickProgress(pb , tokens = list (what = paste0( fconns [[ n ]] @ name , " : " , msg ) ))
86+ .tickProgress(pb , tokens = list (what = msg ))
8787 }
8888 } else {
8989 completed [[n ]] <- TRUE
90- .tickProgress(pb , tokens = list (what = paste0(fconns [[n ]]@ name , " : " , msg )))
9190 }
9291 if (completed [[n ]] && .is.callback(success )) {
9392 success(n )
@@ -117,7 +116,7 @@ datashield.sessions <- function(conns, async=TRUE, success=NULL, error=NULL, err
117116 } else if (! is.null(dsIsAsync(conns )$ session )) {
118117 tryCatch({
119118 if (! dsHasSession(conns )) {
120- dsSession(conns , async = FALSE )
119+ dsSession(conns , async = FALSE )
121120 }
122121 if (.is.callback(success )) {
123122 success(conns @ name )
0 commit comments