var dat = require('dat');
var vdat = require('vinyl-dat');
var debug = require('gulp-debug');
 
// new gulp task with callback
gulp.task('demo', function (cb) {
 
  // new dat database instance
  var db = dat('path/to/dat/database', function (err) {
    if (err) return cb(err);
 
    // new stream from dat
    var stream = vdat.src(db)
      // show each record
      .pipe(debug())
      // write changed records to same database
      .pipe(vdat.dest(db));
 
    // use stream on end to close the database when finished
    stream.on('end', function () {
      db.close(cb);
    });
 
  });
});