Published
Edited
May 8, 2020
1 star
md`# Factorial with Streams!`
factorial(100)
factorial = (n) => integersStream()
.scan1((a, b) => BigInt(a) * BigInt(b))
.take(n)
.last()
.toPromise(Promise)
{
const stream = integersStream().flatMap(delay(1000))
return observeHighland(
stream
.zip(
stream
.observe()
.scan1((a, b) => BigInt(a) * BigInt(b))
)
.map(([n, factorial]) => ({ n, factorial }))
)
}
observeHighland(
integersStream()
.flatMap(delay(1000))
)
integersStream = () => highland(integersGenerator())
integersGenerator = function* () {
let i = 1
while(true) yield i++
}
import {observeHighland, delay} from '@jessevarnado/highland-js-examples'
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.
