raimohanska

fs = require("fs")
Bacon = require("baconjs")

# Bacon.fromNodeStream converts Node.js ReadableStream into an EventStream
Bacon.fromNodeStream = (stream) ->
  Bacon.fromBinder (sink) ->
    listeners = {}
    addListener = (event, listener) ->
      listeners[event] = listener
      stream.on event, listener

raimohanska

func Map[A any, B any](things []A, mapper func (x A) B) []B {
	result := make([] B, len(things))
	for i := range(things) {
		result[i] = mapper(things[i])
	}
	return result
} 

func Filter[A any](things []A, predicate func (x A) bool) []A {
	result := make([] A, len(things))

raimohanska

import nextJs from "next"

async function createNextAppWithCustomLogging() {
  const nextApp = nextJs({ dev: false })
  const server = (await (nextApp as any).getServer()) as any
  if (!(server.logError instanceof Function)) throw Error("Assertion fail")
  server.logError = (err: Error) => {
    logger.error(err)
  }
  return nextApp

raimohanska

int SIGNAL_LED = 13;
int POWER_LED = 11;

byte buffer[100];
byte myAddress[] = {-1, -114, 70, -125};

void setup() {
  Serial.begin(9600);
  pinMode(SIGNAL_LED, OUTPUT);
  pinMode(POWER_LED, OUTPUT);

raimohanska

The key to glitch prevention is the UpdateBarrier. This component takes care of starting and finishing event transactions. The inTransaction function is used to wrap all event handling, creating a transaction that lasts until the original event and all derived events (those created when passing the event through all the maps, combines etc) have been processed.

In the end of the transaction, a flush occurs. During flush, all pending actions are performed. And what are these action then? They are actions registered using the whenDoneWith function, and are basically requests like "please run this function when the dependencies certain observable have been fully flushed". To satisfy these request, the Up

raimohanska

#!/usr/bin/env node
if (process.argv.length != 3) {
  console.error("Usage: psqlurl <url>")
  console.error("Expected one argument, got " + (process.argv.length - 2))
  process.exit(1)
}
var input = process.argv[2]
var URL = require("url")
var ps = require("child_process")
var url = URL.parse(input)

raimohanska

module PrincessVsLion where
import Keyboard

data GameState = Ongoing Int Int | LionWon | PrincessWon

proceedGame keyPresses state = case state of
  Ongoing princess lion ->
      checkEnd (princess + (keyPresses `div` 2)) (lion + 1)
  x -> checkRestart keyPresses x

raimohanska

fs=require "fs"
Bacon=require "baconjs"
Bacon.watchFile = (filename) ->
  Bacon.fromBinder (sink) ->·
    w = fs.watch filename, sink
    -> w.close()
Bacon.watchFile("lol.txt").log()

raimohanska

module PrincessVsLion where
import Keyboard

-- character positions
princess = foldp inc 4 (pressesOf Keyboard.space)
lion = foldp inc 0 (fps 2)

-- combined game state
gameState = lift2 makeState princess lion

raimohanska

Bacon.Observable.prototype.logWithTimestamp = function() {
  var args = Array.prototype.slice.call(arguments, 0)
  this.onValue(function(value) {
    console.log.apply(console, [new Date().getTime()].concat(args.concat([value])))
  })
  return this
}