Stratos Pavlakis th3hunt

The introduction to Reactive Programming you've been missing

So you're curious in learning this new thing called (Functional) Reactive Programming (FRP).

Learning it is hard, even harder by the lack of good material. When I started, I tried looking for tutorials. I found only a handful of practical guides, but they just scratched the surface and never tackled the challenge of building the whole architecture around it. Library documentations often don't help when you're trying to understand some function. I mean, honestly, look at this:

Rx.Observable.prototype.flatMapLatest(selector, [thisArg])

Projects each element of an observable sequence into a new sequence of observable sequences by incorporating the element's index and then transforms an observable sequence of observable sequences into an observable sequence producing values only from the most recent observable sequence.

	/* This shows how to use Object.create */

	/ BASE MODEL ********************************/

	function BaseModel(collection) {
	this.collection = collection;
	}

	BaseModel.prototype.getCollection = function() {
	return this.collection;

	var args = process.argv.slice(2),

	PROJECT_ID = args[0],
	FAULT_ID = args[1],

	// MONGO
	MONGODB_URI = 'mongodb://localhost:27017/honeybadger',
	mongodb = require('mongodb'),
	mongoclient,
	collection,

	(function (root, factory) {
	if(typeof define === "function" && define.amd) {
	// Now we're wrapping the factory and assigning the return
	// value to the root (window) and returning it as well to
	// the AMD loader.
	define(["postal"], function(postal){
	return (root.myModule = factory(postal));
	});
	} else if(typeof module === "object" && module.exports) {
	// I've not encountered a need for this yet, since I haven't

	// Support routines for automatically reporting user timing for common analytics platforms
	// Currently supports Google Analytics, Boomerang and SOASTA mPulse
	// In the case of boomerang, you will need to map the event names you want reported
	// to timer names (for mPulse these need to be custom0, custom1, etc) using a global variable:
	// rumMapping = {'aft': 'custom0'};
	(function() {
	var wtt = function(n, t, b) {
	t = Math.round(t);
	if (t >= 0 && t < 3600000) {
	// Google Analytics

	// backbone.fwd
	// ------------
	// Forward events from a source, through a target object
	//
	// v0.1.0
	// Copyright (C)2014 Muted Solutions, LLC.
	// Distributed under MIT license
	//
	// https://github.com/derickbailey/backbone.fwd

	// simple usage
	// 2 retries on S3
	$('input#file').s3upload({
	registerUrl: 'foo/bar',
	registerMethod: 'PUT',
	submitStrategy: {
	retries: 2
	}
	})

	var errorRenderer = {

	valid: function (view, attr, selector) {
	var control, group;
	control = view.$('[' + selector + '=' + attr + ']');
	group = control.parents(".control-group");
	group.removeClass("error");
	if (control.data("error-style") === "tooltip") {
	if (control.data("tooltip")) {
	return control.tooltip("hide");

	require 'json_responder'
	class Api::V1::ApiController < ActionController::Base
	respond_to :json
	before_filter :authenticate_user
	self.responder = JsonResponder

	rescue_from ActiveRecord::RecordNotFound, with: :not_found
	rescue_from ActiveModel::MassAssignmentSecurity::Error, with: :bad_request
	rescue_from AccessForbidden, with: :access_forbidden
	rescue_from InvalidTransition, with: :invalid_transition

	{
	/* Globals */
	// To ignore any custom global variables, enable the `predef` option and list
	// your variables within it.
	"predef": [
	"window",
	"document",
	"jQuery",
	"Backbone",
	"Marionette",