fuunnx

import Rx from 'rx'


// sources$
const request$ = new Rx.Subject()

const http = require('http')
const fs = require('fs')
const hostname = '127.0.0.1'
const port = 1337

fuunnx

/*
I have a queue that clients submit tasks to, this backend worker consumes them

firebaseDriver: provides a function that generates a one-element observable of a firebase location
queueConsumerDriver: provides a source of all incoming requests, consumes a sink that takes responses
  knows via the uid in the response what channel to send it back on
*/

import {makeFirebaseDriver, makeQueueConsumerDriver} from 'cyclic-fire'

fuunnx

// Generic helper function that takes a main() (the top-level component)
// and wraps it with Stanga logic

function wrapWithStanga(main, initialState) {
  return function (sources) {
    const modProxy$ = new Subject();
    const modelSource = Model(initialState)(modProxy$);
    sources.model = modelSource;
    const sinks = main(sources);
    sinks.model.subscribe(modProxy$);

fuunnx

var ReactDom = require("react-dom");
var Redux = require("redux");
var ReactRouter = require("react-router");
var ReactRedux = require("react-redux");

var ExtractTextPlugin = require("extract-text-webpack-plugin");

var window={}

var getElementsByTagName = function (b) {

fuunnx

made with esnextbin

fuunnx

.Checkbox input {
 width: 0;
 height: 0;
 opacity: 0;
}
.Checkbox input + label {
 display: block;
 width: 1rem;
 height: 1rem;
 background: grey;

fuunnx

import {addResizeListener} from './resizeListener'
import canvasPixelRatio from './pixelRatio'

export class FlexibleCanvas extends HTMLDivElement {
  static get observedAttributes() {return ['width', 'height', 'pixelRatio'] }

  createdCallback () {
    this.canvas = this.appendChild(document.createElement('canvas')) //eslint-disable-line
    this.canvas.setAttribute('style', `
display: block;\

fuunnx

const typeButton = extended({
  attrs: {
    type: 'button',
  },
})

const blueBackground = extended({
  style: {
    'background-color': 'blue',
    'color': 'white',

fuunnx

import fromEvent from 'xstream/extra/fromEvent'
import xs from 'xstream'

export default function jqueryDriver () {
  return (instruction$) => {
    instruction$.addListener({
      next: fn => {
        if (typeof fn === 'function') {fn()}
        else {fn.call()}
      },

fuunnx

```sh
mkdir patches
mv snabbdom+0.7.0.patch patches/snabbdom+0.7.0.patch
npm install snabbdom@0.7.0 patch-package@5.1.1 && ./node_modules/.bin/patch-package
```