{
const ref1 = new AdaptonRef()
const ref2 = new AdaptonRef()
const cell1 = new Adapton(async () => {
function $(ref1, ref2) {
return ref1 + ref2
}
const $$ = await Promise.all([
ref1.compute(cell1),
ref2.compute(cell1),
])
return $(...$$)
})
ref1.set(2)
ref2.set(3)
yield await cell1.compute()
ref2.set(7)
yield await cell1.compute()
}
class Adapton {
constructor(thunk) {
this._thunk = thunk
this._promise = Promise.resolve(null)
this._isClean = false
this._childAdaptons = new Set()
this._parentAdaptons = new Set()
}
dirty() {
if (this._isClean) {
this._isClean = false
for (const parentAdapton of this._parentAdaptons) {
parentAdapton.dirty()
}
}
}
async compute(parentAdapton = null) {
const result = await this._compute(parentAdapton)
if (parentAdapton) {
addEdge(parentAdapton, this)
}
return result
}
async _compute() {
if (this._isClean) {
return await this._promise
}
for (const childAdapton of new Set(this._childAdaptons)) {
removeEdge(this, childAdapton)
}
this._isClean = true
this._promise = this._thunk()
return this.compute()
}
}
class AdaptonRef extends Adapton {
constructor(value) {
super(async () => await this._promise)
this._promise = Promise.resolve(value)
this._isClean = false
}
set(value) {
this._promise = Promise.resolve(value)
this.dirty()
}
}
function addEdge(parentAdapton, childAdapton) {
parentAdapton._childAdaptons.add(childAdapton)
childAdapton._parentAdaptons.add(parentAdapton)
}
function removeEdge(parentAdapton, childAdapton) {
parentAdapton._childAdaptons.delete(childAdapton)
childAdapton._parentAdaptons.delete(parentAdapton)
}
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.
