Discover gists

Cycle.js approach to handling IO looks similar to how it was done in earlier FRP implementations. That seems to be an independent discovery, and that's always even better.

Yampa provides a function reactimate:

:: IO a	-- ^ IO initialization action
-> (Bool -> IO (DTime, Maybe a)) -- ^ IO input sensing action
-> (Bool -> b -> IO Bool)        -- ^ IO actuaction (output processing) action
-> SF a b	-- ^ Signal function

made with esnextbin

~/code/most/most-subject/perf subject-class* 19s
❯ node ./filter-map-reduce.js
filter -> map -> reduce 1000000 integers
-----------------------------------------------
most         14.20 op/s ±  0.83%   (68 samples)
xstream      21.91 op/s ±  1.90%   (29 samples)
rx 5          4.68 op/s ±  1.12%   (16 samples)
-----------------------------------------------

	import { createStore, applyMiddleware } from 'redux';
	import { Observable, Subject } from 'rxjs';

	const api = type => {
	console.log(`calling API ${type}`);
	return new Promise(res => setTimeout(() => res(), 500));
	};

	const actionOrder = (actions, order) => actions.every((action, index) => action.type === order[index]);
	const actionPredicate = actions => filterableAction => actions.some(action => action === filterableAction.type);

	import React from 'react';

	export class Sto extends React.Component{
	static defaultProps = {
	store: x => x
	}
	state = {
	value: this.props.store()
	}
	dispatch = action => this.setState({

	import {run} from '@cycle/xstream-run'
	import {makeDOMDriver, div, input, button, label} from '@cycle/dom'
	import {makeLocalStorageDriver} from 'cyclejs-storage'
	import Collection from '@cycle/collection'
	import xs from 'xstream'
	import debounce from 'xstream/extra/debounce'
	import dropRepeats from 'xstream/extra/dropRepeats'
	import pairwise from 'xstream/extra/pairwise'
	import delay from 'xstream/extra/delay'
	import concat from 'xstream/extra/concat'

	<!doctype html>
	<html>
	<head>
	<script src="shadow-root.js"></script>
	</head>
	<div>
	<div slot="main">
	I'm some projected content.
	</div>
	<shadow-root>

	import SimpleHTTPServer
	class CORSHTTPRequestHandler(SimpleHTTPServer.SimpleHTTPRequestHandler):
	def send_head(self):
	"""Common code for GET and HEAD commands.

	This sends the response code and MIME headers.

	Return value is either a file object (which has to be copied
	to the outputfile by the caller unless the command was HEAD,
	and must be closed by the caller under all circumstances), or

	# .config/fish/config.fish
	function setenv; set -gx $argv; end
	source ~/.env