Joe K jokecamp

## store.ts
import { BehaviorSubject, distinctUntilChanged, map, Observable } from "rxjs";

/**
 * A generic class to manage state in an asynchronous way.
 */
class Store<T> {
  /**
   * @private field to store and notify state changes
   * BehaviorSubject is a special type of Observable
   * that keeps hold of the current value

## Global.asax
public class WebApplication : System.Web.HttpApplication
{
    protected void Application_Start()
    {
        RouteTable.Routes.MapRoute("HttpProxy", "proxy/{*path}", new { controller = "Proxy", action = "Http" })
    }
}

## server.js
var path = require('path');
var fs = require('fs');
var os = require('os');
var express = require('express');
var app = express();
var Busboy = require('busboy');

app.get('/', function (req, res) {
    res.send('<html><head></head><body>\
               <form method="POST" enctype="multipart/form-data">\

## setup-rabbitmq-cluster.sh
#!/bin/bash
set -e

# This script is part of my blog post :
# http://thoughtsimproved.wordpress.com/2015/01/03/tech-recipe-setup-a-rabbitmq-cluster-on-ubuntu/

# It sets up a RabbitMQ cluster by connecting to user-provided master and slave servers
# and ringing them up to a cluster on the fly.

# RabbitMQ Clustering is described in detail here :

## product_generator.rb
#------------------------------------------------------------------------
# encoding: utf-8
# @(#)product_generator.rb	1.00 29-Nov-2011 16:38
#
# Copyright (c) 2011 Jim Pravetz. All Rights Reserved.
# Licensed under the MIT license (http://www.opensource.org/licenses/mit-license.php)
#
# Description:  A generator that creates product, products and
#		ingredients pages for jekyll sites.  Uses a JSON data
#		file as the database file from which to read and

## flow-uploader.js
'use strict';

const fs = Promise.promisifyAll(require('fs'));
const path = require('path');
const crypto = require('crypto');
const CronJob  = require('cron').CronJob;

module.exports = class FlowUploader {
    constructor(tempDir, uploadDir, maxFileSize, fileParameterName) {
        this.tempDir = tempDir || './tmp';
	import { BehaviorSubject, distinctUntilChanged, map, Observable } from "rxjs";

	/**
	* A generic class to manage state in an asynchronous way.
	*/
	class Store<T> {
	/**
	* @private field to store and notify state changes
	* BehaviorSubject is a special type of Observable
	* that keeps hold of the current value
	public class WebApplication : System.Web.HttpApplication
	{
	protected void Application_Start()
	{
	RouteTable.Routes.MapRoute("HttpProxy", "proxy/{*path}", new { controller = "Proxy", action = "Http" })
	}
	}
	var path = require('path');
	var fs = require('fs');
	var os = require('os');
	var express = require('express');
	var app = express();
	var Busboy = require('busboy');

	app.get('/', function (req, res) {
	res.send('<html><head></head><body>\
	<form method="POST" enctype="multipart/form-data">\
	#!/bin/bash
	set -e

	# This script is part of my blog post :
	# http://thoughtsimproved.wordpress.com/2015/01/03/tech-recipe-setup-a-rabbitmq-cluster-on-ubuntu/

	# It sets up a RabbitMQ cluster by connecting to user-provided master and slave servers
	# and ringing them up to a cluster on the fly.

	# RabbitMQ Clustering is described in detail here :
	#------------------------------------------------------------------------
	# encoding: utf-8
	# @(#)product_generator.rb 1.00 29-Nov-2011 16:38
	#
	# Copyright (c) 2011 Jim Pravetz. All Rights Reserved.
	# Licensed under the MIT license (http://www.opensource.org/licenses/mit-license.php)
	#
	# Description: A generator that creates product, products and
	# ingredients pages for jekyll sites. Uses a JSON data
	# file as the database file from which to read and
	'use strict';

	const fs = Promise.promisifyAll(require('fs'));
	const path = require('path');
	const crypto = require('crypto');
	const CronJob = require('cron').CronJob;

	module.exports = class FlowUploader {
	constructor(tempDir, uploadDir, maxFileSize, fileParameterName) {
	this.tempDir = tempDir \|\| './tmp';