const { createReadStream } = require('fs')
const { join } = require('path')
const capnp = require('capnp')
const { ParseStream } = require('capnp-stream')
 
// import capnp schema
const schema = capnp.import(join(__dirname, 'person.capnp'))
 
// initialize stream for a given schema
const capnpStream = new ParseStream(schema.Person)
 
// print as a JSON every object in the stream
capnpStream.on('data', (d) => {
  console.log(JSON.stringify(d, null, 2))
})
 
// pipe the data file to the capnp-stream instance
createReadStream('someCapnpDataFile')
  .pipe(capnpStream)

const { createWriteStream } = require('fs')
const { join } = require('path')
const capnp = require('capnp')
const { SerializeStream } = require('capnp-stream')
 
// import capnp schema
const schema = capnp.import(join(__dirname, 'person.capnp'))
 
// initialize stream for a given schema
const capnpStream = new SerializeStream(schema.Person)
 
someObjectsStream // a stream that emits JavaScript objects that conform the capnp Schema
  .pipe(capnpStream) // encodes the javascript objects to a capnp stream
  .pipe(createWriteStream(join(__dirname, 'somefile.dat'))) // save the encoded capnp data to a file

const capnp = require('capnp')
const { SerializeStream } = require('capnp-stream')
 
// import capnp schema
const schema = capnp.import(join(__dirname, 'person.capnp'))
 
// initialize stream for a given schema
const capnpStream = new SerializeStream(schema.Person, {
  skip: process.env.SKIP,
  emitEvery: process.env.EMIT_EVERY
})