git ssb

Watch for messages by all users

var pull = require('pull-stream')
pull(
  sbot.createLogStream({ live: true }),
  pull.drain(function (msg) { ... })
)

sbot log --live

→ createLogStream API

Watch for messages by a single user

var pull = require('pull-stream')
pull(
  sbot.createUserStream({ id: userId, live: true }),
  pull.drain(function (msg) { ... })
)

sbot createUserStream --id {userId} --live

Notice that pull.drain is used instead of pull.collect, so that new messages are handled immediately.

→ createUserStream API