| license: gpl-3.0 |
| license: mit |
| 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); | |
| } |
| version: '2.1' | |
| services: | |
| node: | |
| build: . | |
| env_file: .env | |
| working_dir: /usr/src/app | |
| volumes: | |
| - ./:/usr/src/app | |
| depends_on: | |
| - mongo |
Hey there.
My name's Paul, and I'm a software developer and data journalist at the New York Times' Interactive News Desk.
I was previously a student of the Creative Coding Research Group in the Electronic Visualization Lab at the University of Illinois at Chicago. The group, led by Angus Forbes, is engaged in an interdisciplinary mix of visualization research and new media artwork.
| node_modules |
This example demonstrates how to build a nested hierarchy from a streaming datasource.
Groups in the hierarchy are generated and sorted "on demand" as they are pulled from the data$ Observable.
Rx.Observable.groupBy() produces GroupedObservables which are scanned into arrays and then combined using flatMapLatest(Rx.Observable.combineLatest).
(Note: It's important to shareReplay the GroupedObservables)
This example also uses babel-standalone to enable in-browser ES6 features.
| license: gpl-3.0 |
| license: gpl-3.0 |
To transition an HTML list when it is re-ordered:
<li> contains an empty character.<li>'s new position (using jQuery).absolute-ly positioned list elements.🆒