In ElianHugh/emitters: NodeJS-inspired events and io streams.

knitr::opts_chunk$set(
  collapse = TRUE,
  comment = "#>"
)

library(emitters)

x <- ReadableStream$new(mtcars) %|>%
  map_stream(
    function(data) {
      return(data) # do nothing
    }
  ) %|>%
  WriteableStream$new(list())


x$writeable_state$source$as_list()

ElianHugh/emitters documentation built on Feb. 6, 2022, 4:55 a.m.