Notebooks 2.0 is here.
Read the preview announcement
Platform
Resources
Pricing
Sign in
Get started
Jesse Varnado
Workspace
Fork
Published
By
Jesse Varnado
Edited
May 16, 2019
Fork of
Streams with Promise Transformations
1 star
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
Insert cell
stream
=
highland
(
eternalIterable
(
)
)
.
through
(
strategies
[
currentStrategy
]
)
.
flatMap
(
v
=>
highland
(
formatPromise
(
v
)
)
)
Insert cell
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
}`
)
)
,
}
)
Insert cell
Insert cell
Insert cell
formatPromise
=
v
=>
bluebird
.
delay
(
delayTime
)
.
return
(
`Current value is ${
v
}`
)
Insert cell
Insert cell
Insert cell
moment
=
require
(
'moment'
)
Insert cell
highland
=
require
(
'highland@2.13.4/dist/highland.js'
)
Insert cell
bluebird
=
require
(
'bluebird'
)
Insert cell
import
{
button
}
from
"@jashkenas/inputs"
Insert cell
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.
Try it for free
Learn more
Compare fork
Fork
View
Export
Edit
Add comment
Select
Duplicate
Copy link
Embed
Delete
JavaScript
Markdown
HTML
Edit
Add comment
Select
Duplicate
Copy link
Embed
Delete
JavaScript
Markdown
HTML
currentStrategy
Edit
Add comment
Copy import
Select
Duplicate
Copy link
Embed
Delete
JavaScript
Markdown
HTML
Edit
Add comment
Select
Duplicate
Copy link
Embed
Delete
JavaScript
Markdown
HTML
currentNumber
Edit
Add comment
Copy import
Select
Duplicate
Copy link
Embed
Delete
JavaScript
Markdown
HTML
strategyToggle
Edit
Add comment
Copy import
Select
Duplicate
Copy link
Embed
Delete
JavaScript
Markdown
HTML
stream
Add comment
Copy import
Select
Duplicate
Copy link
Embed
Delete
JavaScript
Markdown
HTML
strategies
Add comment
Copy import
Select
Duplicate
Copy link
Embed
Delete
JavaScript
Markdown
HTML
batches
Edit
Add comment
Copy import
Select
Duplicate
Copy link
Embed
Delete
JavaScript
Markdown
HTML
delayTime
Edit
Add comment
Copy import
Select
Duplicate
Copy link
Embed
Delete
JavaScript
Markdown
HTML
formatPromise
Add comment
Copy import
Select
Duplicate
Copy link
Embed
Delete
JavaScript
Markdown
HTML
Edit
Add comment
Select
Duplicate
Copy link
Embed
Delete
JavaScript
Markdown
HTML
eternalIterable
Edit
Add comment
Copy import
Select
Duplicate
Copy link
Embed
Delete
JavaScript
Markdown
HTML
moment
Add comment
Copy import
Select
Duplicate
Copy link
Embed
Delete
JavaScript
Markdown
HTML
highland
Add comment
Copy import
Select
Duplicate
Copy link
Embed
Delete
JavaScript
Markdown
HTML
bluebird
Add comment
Copy import
Select
Duplicate
Copy link
Embed
Delete
JavaScript
Markdown
HTML
Add comment
Copy import
Select
Duplicate
Copy link
Embed
Delete
JavaScript
Markdown
HTML