git ssb

1
var Flume = require('flumedb')
2
var FlumeLog = require('flumelog-offset')
3
var codec = require('flumecodec')
4
var pull = require('pull-stream')
5
var path = require('path')
6
7
const log = FlumeLog('demo_log', { codec: codec.json })
8
9
var db = Flume(log)
10
11
pull(
12
  db.stream({ live: true }),
13
  pull.drain(
14
    viewState => {
15
      console.log('FlumeDB.stream:', viewState)
16
      console.log()
17
    }, 
18
    () => console.log('DONE: db stream')
19
  )
20
)
21
22
pull(
23
  pull.values([1,2,3,4,5,6,7]),
24
  pull.asyncMap((val, cb) => setTimeout(
25
    () => cb(null, val), 
26
    500
27
  )),
28
  pull.drain(
29
    val => db.append({ count: val }, (err, seq) => {
30
      console.log(`FlumeDB.append: appended '${val}' at offset of ${seq} bytes`)
31
      console.log()
32
    }),
33
    () => console.log('DONE: append stream')
34
  )
35
)
36