diff --git a/src/common.ts b/src/common.ts
index f6eb7eb..d2c197f 100644
--- a/src/common.ts
+++ b/src/common.ts
@@ -51,13 +51,13 @@ export class PushOnlyObserver implements BListener, SListener {
pushB(t: number): void {
this.callback((>this.source).last);
}
- pushS(t: number, value: A): void {
+ pushS(_t: number, value: A): void {
this.callback(value);
}
deactivate(): void {
this.source.removeListener(this.node);
}
- changeStateDown(state: State): void {}
+ changeStateDown(_state: State): void {}
}
export type NodeParentPair = {
@@ -144,10 +144,10 @@ export class CbObserver implements BListener, SListener {
this.callback(this.source.last);
}
}
- pushB(t: number): void {
+ pushB(_t: number): void {
this.callback((>this.source).last);
}
- pushS(t: number, value: A): void {
+ pushS(_t: number, value: A): void {
this.callback(value);
}
changeStateDown(state: State): void {
diff --git a/src/now.ts b/src/now.ts
index 4f411c2..13a3b1d 100644
--- a/src/now.ts
+++ b/src/now.ts
@@ -242,15 +242,6 @@ export function performStreamOrdered(s: Stream>): Now> {
return new PerformStreamOrderedNow(s);
}
-class PlanNow extends Now> {
- constructor(private future: Future>) {
- super();
- }
- run(time: Time): Future {
- return this.future.map((n) => n.run(time));
- }
-}
-
export function plan(future: Future>): Now> {
return performMap, A>(runNow, future);
}