jhusain

someObservable.retry(3)

consts tasks = 
{
....{....5......2.......3...}
............{......5............4....3}
............................................{5...2...4}
.....................................................{...5}
}

jhusain

function fromEvent(dom, eventName) {
    return {
        forEach: function(observer) {
            var handler = (e) => {
                observer.onNext(e);
            };
            dom.addEventListener(eventName, handler);

            // Subscription
            return {

jhusain

/*
Bar Problem
N friends are playing a game. Each of them has a list of numbers in front of himself.

Each of N friends chooses a number from his list and reports it to the game administrator. Then the game administrator sorts the reported numbers and shouts the K-th largest number.

You want to know the count all possible numbers that the game administrator can shout.

jhusain

https://github.com/Netflix/falcor-path-utils/blob/master/lib/toTree.js

[
  ["list",{from:0,to:9],["name","rating"]],
  ["list", "length"]
]

->

{

jhusain

var print = console.log.bind(console);

// partial implementation of Array.from
Array.from = function(iterable) {
    var results = [];
    for(var x of iterable) {
        results.push(x);
    }
    return results;
};

jhusain

module Main where

import Prelude

import Control.Monad.Eff (Eff)
import Data.Foldable (fold)
import TryPureScript (DOM, h1, h2, p, text, list, indent, link, render, code)

type Video = { name:: String }

jhusain

import cyclops.control.Unrestricted;
import io.reactivex.Observable;


public class ObservableInterpreter {

    public static <R> Observable<R> interpret(Unrestricted<R> program){
        //walk the Free data structure and handle each command,

jhusain

interface Combinable<T> {
    plus(T): T,
    zero(): T    
}

class Max implements Combinable<Max> {
    private value: number
    constructor(num: number) {
        this.value = num;
    }

jhusain

module Main where

import Prelude

import Control.Monad.Eff (Eff)
import Data.Foldable (fold)
import TryPureScript (DOM, h1, h2, p, text, list, indent, link, render, code)
import Data.Map (Map, lookup, insert, empty)
import Data.List
import Data.Either

jhusain

class Observable<T, E> {

  // cant be typed in flow, but perhaps we can
  // somehow declare several overloads? 
  // pipe(Observable<T0, E0> => Observable<T1, E1>): Observable<T1, E1>
  // pipe(Observable<T0, E0> => Observable<T1, E1>, Observable<T1, E1> => Observable<T2, E2>): Observable<T2, E2>
  // etc...
  pipe(...operators) {
    return operators.reduce((acc, curr) => curr(acc), this);
  }