How to use the unique function from pull-stream

resolvers.js

GitHub: planetary-social/planetary-graphql

98
99
100
101
102
103
104
105
106
107
  descending(), // latest => oldest
  toPullStream()
),
pull.filter(m => m.value.author === m.value.content.about),
pull.map(m => m.value.author),
pull.unique(),
pullParaMap((feedId, cb) => {
  getProfile(feedId)
    .then(profile => cb(null, profile))
    .catch(err => cb(err))

2

3

0

+ 2 other calls in file

index.js

GitHub: ssbc/ssb-tribes2

198
199
200
201
202
203
204
205
206
207
    ),
    pull.map((msg) => lodashGet(msg, 'value.content.recps', [])),
    pull.filter((recps) => recps.length > 1 && recps[0] === groupId),
    pull.map((recps) => recps.slice(1)),
    pull.flatten(),
    pull.unique()
  )
}

function listInvites() {

1

7

4

+ 32 other calls in file

meta-feed-helpers.js

GitHub: ssbc/ssb-tribes2

61
62
63
64
65
66
67
68
69
70
      }
    })
  )
}),
pull.filter(),
pull.unique('id'),
pull.take(1),
pull.drain(
  (emptyFeed) => {
    found = true

1

7

0

+ 2 other calls in file