Commit 89d04b0f0784096d39f86b2f8cd93579dabc8643
remove pull-streams
Piet Geursen committed on 3/12/2018, 1:29:04 AMParent: f78534ebf7392f78ee9dd0bde9bb8dcad341bc48
Files changed
| position/async/position.js | changed |
| position/async/position.js | |||
|---|---|---|---|
| @@ -22,17 +22,12 @@ | |||
| 22 | 22 … | content.channel = channel | |
| 23 | 23 … | } | |
| 24 | 24 … | ||
| 25 | 25 … | if (content.root && server) { | |
| 26 | - pull( | ||
| 27 | - pullAsync(cb => { | ||
| 28 | - getPoll(content.root, cb) | ||
| 29 | - }), | ||
| 30 | - pull.drain(({positions}) => { | ||
| 31 | - content.branch = sort.heads(positions) | ||
| 32 | - cb(null, content) | ||
| 33 | - }) | ||
| 34 | - ) | ||
| 26 … | + getPoll(content.root, (err, {positions}) => { | ||
| 27 … | + content.branch = sort.heads(positions) | ||
| 28 … | + cb(err, content) | ||
| 29 … | + }) | ||
| 35 | 30 … | } else { | |
| 36 | 31 … | cb(null, content) | |
| 37 | 32 … | } | |
| 38 | 33 … | ||
Built with git-ssb-web