mafintosh

const speedometer = require('speedometer')

const speed = speedometer()

setInterval(function () {
  console.log(speed())
}, 1000)

const udp = chrome.sockets.udp
udp.create({}, function (res) {

mafintosh

const stream = require('stream')

const r = new stream.Readable({
  read () {
    this.push('hello')
    this.push('world')
    this.push(null)
  }
})

mafintosh

/usr/bin/python2.7 tools/gyp_node.py -f make
  File "<string>", line 1
    import sys; print sys.byteorder
                        ^
SyntaxError: invalid syntax
gyp: Call to 'python -c "import sys; print sys.byteorder"' returned exit status 1 while in /home/maf/dev/node/deps/v8/gypfiles/v8.gyp.
make: *** [Makefile:130: out/Makefile] Error 1

mafintosh

Using shared-structs with Workers <3

This showcases how you can use shared-structs over an SharedArrayBuffer, to share complex data structures between worker_threads in Node.js

The main.js example starts a worker and passes a shared struct to it.

The worker will periodically update the struct with an incrementing tick and a random number

mafintosh

function injectEvent (e, name, fn) {
  if (!e._events[name]) e._events[name] = []
  e._events[name].push(fn)
  e._eventsCount++
}

mafintosh

const toString = require('tree-to-string')
const util = require('util')

module.exports = BTree

function BTree () {
  this.feed = []
}

BTree.prototype.put = function (key, value) {

mafintosh

                    [ 1 ]─┐
                          ├─[ 2 ]─┐
                    [ 3 ]─┘       │
                                  ├─[ 3.1 ]─┐
                [ 3.2 ]─┐         │         │
                        ├─[ 3.3 ]─┘         │
                [ 3.4 ]─┘                   │
                                            ├─[ 3.5 ]─┐
                  [ 3.6 ]─┐                 │         │

mafintosh

(module
  (memory (export "memory") 10 10000)

  (func (export "index_of") (param $start i32) (param $end i32) (param $needle i32) (result i32)
    (block $end_loop
      (br_if $end_loop (i32.eq (get_local $start) (get_local $end)))
      (if (i32.eq (i32.load8_u (get_local $start)) (get_local $needle))
        (then (return (get_local $start)))
      )
      (set_local $start (i32.add (i32.const 1) (get_local $start)))

mafintosh

• Streams cookbook.
• How do we scale the dev?
• Document the userland modules.
• Add tests for the event ordering.
• Use readable-stream as the issue tracker / call to action for streams.
• We need mini streams summit.

mafintosh

// by @noffle

autoinstall () {
  local MODULES=$(cat $1 | grep "require('.*')" | sed "s/.*require('\(.*\)')/\1/" | grep -v '^\.' | tr '\n' ' ')
  shift
  shift
  npm install $MODULES $@
}