R/binary.readable.connection.r

In datapackage.r: Data Package 'Frictionless Data'

#' Binary Readable Connection class
#' @description Binary Readable connection class
#' @docType class
#' @importFrom R6 R6Class
#' @export
#' @include profile.R
#' @keywords data
#' @return Object of \code{\link{R6Class}}.
#' @format \code{\link{R6Class}} object.
#' 

BinaryReadableConnection <- R6::R6Class(
  "BinaryReadableConnection",
  
  public = list(
    initialize = function(options = list()) {
      private$connection_ <- options$source
      private$iterable_ <- iterators::iter(function(){
        if (length(value <- readBin(private$connection_, integer(), size = 1)) > 0) {
          private$index_ <- private$index_ + 1
          
          return(value)
        }
        
        else {
          close(private$connection_)
          stop('StopIteration')
        }
      })
    },
    
    read = function(size = NULL) {
      if (!isTRUE(isOpen(private$connection_))) {
        open(private$connection_, open = "rb")
        
      }
      return(iterators::nextElem(private$iterable_))
    }
    
    
    
  ),
  active = list(
    destroyed = function(value) {
      
    }
    
  ),
  private = list(
    encoding_ = NULL,
    objectMode_ = FALSE,
    read_ = function() {
      browser()
    },
    destroy_ = function() {
      
    },
    buffer_ = list(),
    readable_ = TRUE,
    paused_ = TRUE,
    pipeDestination_ = list(),
    flowing_ = FALSE,
    
    connection_ = NULL,
    iterable_ = NULL,
    index_ = 0
  )
)