reactivePoll and reactiveFileReader

This app has a log file which is appended to every second.

This side uses a reactiveFileReader, which is monitoring the log file for changes every 0.5 seconds.

              
This side uses a reactivePoll, which is monitoring the log file for changes every 4 seconds.

              
show with app
function(input, output, session) {

  # Create a random name for the log file
  logfilename <- tempfile('logfile', fileext = '.txt')

  # ============================================================
  # This part of the code writes to the log file every second.
  # Writing to the file could be done by an external process.
  # In this example, we'll write to the file from inside the app.
  logwriter <- observe({
    # Invalidate this observer every second (1000 milliseconds)
    invalidateLater(1000, session)

    # Clear log file if more than 10 entries
    if (file.exists(logfilename) &&
        length(readLines(logfilename)) > 10) {
      unlink(logfilename)
    }

    # Add an entry to the log file
    cat(as.character(Sys.time()), '\n', file = logfilename,
        append = TRUE)
  })

  # When the client ends the session, suspend the observer and
  # remove the log file.
  session$onSessionEnded(function() {
    logwriter$suspend()
    unlink(logfilename)
  })

  # ============================================================
  # This part of the code monitors the file for changes once per
  # 0.5 second (500 milliseconds).
  fileReaderData <- reactiveFileReader(500, session,
                                       logfilename, readLines)

  output$fileReaderText <- renderText({
    # Read the text, and make it a consistent number of lines so
    # that the output box doesn't grow in height.
    text <- fileReaderData()
    length(text) <- 14
    text[is.na(text)] <- ""
    paste(text, collapse = '\n')
  })


  # ============================================================
  # This part of the code monitors the file for changes once
  # every four seconds.

  pollData <- reactivePoll(4000, session,
    # This function returns the time that the logfile was last
    # modified
    checkFunc = function() {
      if (file.exists(logfilename))
        file.info(logfilename)$mtime[1]
      else
        ""
    },
    # This function returns the content of the logfile
    valueFunc = function() {
      readLines(logfilename)
    }
  )

  output$pollText <- renderText({
    # Read the text, and make it a consistent number of lines so
    # that the output box doesn't grow in height.
    text <- pollData()
    length(text) <- 14
    text[is.na(text)] <- ""
    paste(text, collapse = '\n')
  })
}
fluidPage(
  titlePanel("reactivePoll and reactiveFileReader"),
  fluidRow(
    column(12,
      p("This app has a log file which is appended to",
        "every second.")
    )
  ),
  fluidRow(
    column(6, wellPanel(
      "This side uses a reactiveFileReader, which is monitoring",
      "the log file for changes every 0.5 seconds.",
      verbatimTextOutput("fileReaderText")
    )),

    column(6, wellPanel(
      "This side uses a reactivePoll, which is monitoring",
      "the log file for changes every 4 seconds.",
      verbatimTextOutput("pollText")
    ))
  )
)