This commit is contained in:
haad 2016-03-22 16:36:53 +01:00
parent 4d05f545a4
commit 76a0ad5d52
2 changed files with 3 additions and 3 deletions

View File

@ -61,12 +61,12 @@ class Client {
} }
_onLoad(channel, hash) { _onLoad(channel, hash) {
console.log("Loading #" + channel, hash) // console.log("Loading #" + channel, hash)
this.events.emit('load', channel, hash); this.events.emit('load', channel, hash);
} }
_onLoaded(channel, hash) { _onLoaded(channel, hash) {
console.log("Finished loading #" + channel, hash) // console.log("Finished loading #" + channel, hash)
this.events.emit('loaded', channel, hash); this.events.emit('loaded', channel, hash);
} }

View File

@ -110,7 +110,7 @@ class OrbitDB {
return null; return null;
}; };
// Find an items from the sequence (list of operations) // Find the items from the sequence (list of operations)
return sequence return sequence
.map((f) => await(OrbitDB.fetchPayload(this._ipfs, f.payload))) // IO - fetch the actual OP from ipfs. consider merging with LL. .map((f) => await(OrbitDB.fetchPayload(this._ipfs, f.payload))) // IO - fetch the actual OP from ipfs. consider merging with LL.
.skipWhile((f) => key && f.key !== key) // Drop elements until we have the first one requested .skipWhile((f) => key && f.key !== key) // Drop elements until we have the first one requested