Skip to content
Merged
Show file tree
Hide file tree
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions src/generators/observe.js
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,10 @@ export default function(initialize) {
let resolve;
const dispose = initialize(change);

if (dispose != null && typeof dispose !== "function") {
throw new Error("invalid dispose");
}

function change(x) {
if (resolve) resolve(x), resolve = null;
else stale = true;
Expand Down
4 changes: 4 additions & 0 deletions src/generators/queue.js
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,10 @@ export default function(initialize) {
const queue = [];
const dispose = initialize(push);

if (dispose != null && typeof dispose !== "function") {
throw new Error("invalid dispose");
}

function push(x) {
queue.push(x);
if (resolve) resolve(queue.shift()), resolve = null;
Expand Down