Notebooks 2.0 is here.
stream = highland(eternalIterable())
.through(strategies[currentStrategy])
.flatMap(v => highland(formatPromise(v)))
strategies = ({
foo: stream => stream
.batch(10)
.tap(items => { mutable batches = items }) // this just updates batches for display
.flatMap(items => highland(bluebird.delay(50).return(items).map(item => `foo${item}`)))
.flatten()
,
bar: stream => stream.map(item => (`bar${item}`)),
})
formatPromise = v => bluebird.delay(delayTime).return(`Current value is ${v}`)
moment = require('moment')
highland = require('highland@2.13.4/dist/highland.js')
bluebird = require('bluebird')
import {button} from "@jashkenas/inputs"
Purpose-built for displays of data
Observable is your go-to platform for exploring data and creating expressive data visualizations. Use reactive JavaScript notebooks for prototyping and a collaborative canvas for visual data exploration and dashboard creation.
