Skip to content

Instantly share code, notes, and snippets.

const getObservableAndNext = (baseUrl, firstPage) => {
const subject = new Rx.Subject()
const response$ = subject
.flatMap(page => { return fetch(baseUrl, page) })
.startsWith(firstPage)
const data$ = response.map(response) => { return response.data })
const page$ = response$.map((response) => { return response.nextPage })
@findjashua
findjashua / events.js
Last active June 13, 2016 13:39
Get streams for interaction & mutation events
import {Observable} from 'rx';
import {DOM} from 'rx-dom';
import {toArray, getNodesFromSelector} from './utils';
let interactions_ = {
'click': Observable.fromEvent(document.body, 'click')
}
let mutations_ = DOM
@findjashua
findjashua / ractive-todos.html
Last active August 29, 2015 14:06
Todos with Ractive.js
<!doctype html>
<html>
<head>
<title>Ractive</title>
</head>
<body>
<div id='container'></div>
<script id='todos' type='text/template'>
<div>
module foo
def min(list) when length(list) > 0 do
Enum.min(list)
end
def min([]) do
[]
end
def min(list) do
defmodule Geometry do
@moduledoc "geometric formulae"
import IO
defmodule Quad do
@moduledoc "Quadilateral formulae"
defmodule Rect do
# can't import Geometry
# since inner modules are loaded before outer ones