mirror of
https://github.com/rstudio/shiny.git
synced 2026-02-08 05:35:07 -05:00
2602dc15b0
- Moved (in|de)crementBusyCount calls out of Context and into Observer - decrementBusyCount is (effectively) deferred for async observers until the async operation is complete - invalidateLater didn't force(session), almost certainly was buggy - invalidateLater, reactiveTimer, and manageInputs all now use a new session$cycleStartAction, which delays their effect until observers (including async ones) are done executing
37 lines
865 B
R
37 lines
865 B
R
library(shiny)
|
|
library(future)
|
|
library(promises)
|
|
library(magrittr)
|
|
plan(multisession)
|
|
|
|
ui <- fluidPage(
|
|
p("This app tests that ", tags$code("invalidateLater()"), " calls are held until async operations are complete."),
|
|
tags$ol(
|
|
tags$li("You should see the number below increasing by 1, every 2 seconds."),
|
|
tags$li("The output should be semi-transparent (i.e. recalculating state) continuously."),
|
|
tags$li("You should see the word 'Flushed' in the R console, every 2 seconds.")
|
|
),
|
|
verbatimTextOutput("out")
|
|
)
|
|
|
|
server <- function(input, output, session) {
|
|
|
|
value <- reactiveVal(0L)
|
|
|
|
observe({
|
|
invalidateLater(100)
|
|
isolate({ value(value() + 1L) })
|
|
})
|
|
|
|
session$onFlushed(function() {
|
|
print("Flushed")
|
|
}, once = FALSE)
|
|
|
|
output$out <- renderText({
|
|
future(Sys.sleep(2)) %...>%
|
|
{ value() }
|
|
})
|
|
}
|
|
|
|
shinyApp(ui, server)
|