Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP

Comparing changes

Choose two branches to see what's changed or to start a new pull request. If you need to, you can also compare across forks.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also compare across forks.
  • 2 commits
  • 2 files changed
  • 0 commit comments
  • 1 contributor
Showing with 1 addition and 4 deletions.
  1. +1 −1  package.json
  2. +0 −3  stream.js
View
2  package.json
@@ -2,7 +2,7 @@
"author": "Dominic <dominic.tarr@gmail.com> (http://dominictarr.com)",
"name": "crdt",
"description": "Commutative Replicated Data Types for easy distributed/collaborative apps",
- "version": "1.5.0",
+ "version": "1.5.1",
"homepage": "http://github.com/dominictarr/crdt",
"repository": {
"url": "git://github.com/dominictarr/crdt.git"
View
3  stream.js
@@ -119,7 +119,6 @@ function createReadStream(doc, opts) {
opts = opts || {}
if(opts.end !== false)
opts.end = true
- console.log('CRS', opts)
var s = new Stream()
var queue = []
@@ -144,7 +143,6 @@ function createReadStream(doc, opts) {
}
s.flush = function () {
- console.log('FLUSH')
while(queue.length && !s.paused)
s.emit('data', queue.shift())
if(opts.end && !queue.length && !s.paused && !s.ended) {
@@ -166,7 +164,6 @@ function createReadStream(doc, opts) {
//emitting histroy must be deferred because downstream
//may not yet exist.
//send scuttlebutt greeting
- console.log('PIPE')
queue.push({iam: doc.id})
u.concat(queue, doc.history())

No commit comments for this range

Something went wrong with that request. Please try again.