Files: d170e66ba2918935e031c59b154e8a2b42afb08e / sbot / live-backlinks.js
431 bytesRaw
1 | var pull = require('pull-stream') |
2 | module.exports = function (ssb, config) { |
3 | var subscriptions = new Set() |
4 | return { |
5 | subscribe: function (id) { |
6 | subscriptions.add(id) |
7 | }, |
8 | unsubscribe: function (id) { |
9 | subscriptions.delete(id) |
10 | }, |
11 | stream: function (id) { |
12 | return pull( |
13 | ssb.backlinks.read({old: false, index: 'DTS'}), |
14 | pull.filter(x => subscriptions.has(x.dest)) |
15 | ) |
16 | } |
17 | } |
18 | } |
19 |
Built with git-ssb-web