Stupid stream

stupid.ts

class Stream<T> {
    constructor(private start: Start<T>) {}
    listen(next: Listener<T>) { this.start(next) }
}

class Stream<T> {
    constructor(private start: Start<T>) {}
    compose<U>(fn: (stream: Stream<T>) => Stream<U>): Stream<U> {
        return fn(this);
    }
    listen(next: Listener<T>) { this.start(next) }
}