briancavalier

made with esnextbin

briancavalier

import { tap, take, skip, concat, fromArray, runEffects } from '../packages/core/src/index'
import { newDefaultScheduler } from '../packages/scheduler/src/index'
import { EventEmitter } from 'events'
import multicastStream from '@most/multicast'
import { fromEvent } from 'most'

const emitter = new EventEmitter()

const scheduler = newDefaultScheduler()
const observe = (f, stream) => runEffects(tap(f, stream), scheduler)

briancavalier

made with esnextbin

briancavalier

made with esnextbin

briancavalier

made with esnextbin

briancavalier

made with esnextbin

briancavalier

made with esnextbin

briancavalier

import { readFile } from 'fs'

// Create a stream-returning version of fs.readFile
const readFileS = fromNode(readFile)

// Use it to create a stream containing the files contents
// map(String) to convert Buffer to string
const s = readFileS('./a/file.txt').map(String)

// Observe the contents

briancavalier

function * empty() {}

function * cons (a, stream) {
  yield a
  yield * stream
}

function * concat (xs, ys) {
  yield * xs
  yield * ys

briancavalier

made with esnextbin