How to use the values function from pull-stream

pull-stream.md?plain=1

GitHub: yoshuawuyts/notes

172
173
174
175
176
177
178
179
180
181
-----1--2----3----4--------
         flatten()
-----1--2----3-1--4-2---3--
```
```js
const source = pull.values([
  pull.values([ 1, 2, 3, 4 ]),
  pull.values([ 1, 2, 3 ])
])
const sink = pull.log()

46

839

48

+ 7 other calls in file

index.js

GitHub: ssbc/ssb-db2

353
354
355
356
357
358
359
360
361
362
    encryptionFormat: 'box',
  })

startMeasure(t, 'add 1000 box1 msgs')
pull(
  pull.values(opts),
  pull.asyncMap(sbot.db.create),
  pull.collect((err, msgs) => {
    endMeasure(t, 'add 1000 box1 msgs')
    if (err) t.fail(err)

6

41

0

+ 3 other calls in file

index.js

GitHub: ssbc/ssb-tribes

241
242
243
244
245
246
247
248
249
250
function tribeList (opts, cb) {
  if (typeof opts === 'function') return tribeList({}, opts)

  onKeystoreReady(() => {
    pull(
      pull.values(keystore.group.list()),
      paraMap(tribeGet, 4),
      opts.subtribes
        ? null
        : pull.filter(tribe => tribe.parentGroupId === undefined),

4

27

16

resolvers.js

GitHub: planetary-social/planetary-graphql

72
73
74
75
76
77
78
79
80
81
 * @param {array} feedIds - array of feed ids
 */
const getProfilesForIds = (feedIds) => {
  return new Promise((resolve, reject) => {
    pull(
      pull.values(feedIds),
      pullParaMap((feedId, cb) => {
        getProfile(feedId)
          .then(profile => cb(null, profile))
          .catch(cb)

2

3

0

+ 5 other calls in file

index.js

GitHub: ssbc/ssb-tribes2

204
205
206
207
208
209
210
211
212
213
  )
}

function listInvites() {
  return pull(
    pull.values([0]), // dummy value used to kickstart the stream
    pull.asyncMap((n, cb) => {
      ssb.metafeeds.findOrCreate((err, myRoot) => {
        // prettier-ignore
        if (err) return cb(clarify(err, 'Failed to get root metafeed when listing invites'))

1

7

4

+ 32 other calls in file

get-tangle-data.test.js

GitHub: ssbc/ssb-tribes2

119
120
121
122
123
124
125
126
127
128
const groupId = data.id

//console.time('getTangles')

pull(
  pull.values(publishArray),
  paraMap(
    (value, cb) =>
      server.tribes2.publish(
        { type: 'memo', value, recps: [groupId] },

1

7

0

+ 2 other calls in file

format.js

GitHub: ssbc/ssb-box2

134
135
136
137
138
139
140
141
142
143
  })
}

function listGroupIds(opts = {}) {
  return pull(
    pull.values([0]),
    pull.asyncMap((_, cb) => {
      keyringReady.onReady(() => {
        return cb(null, keyring.group.list({ live: !!opts.live }))
      })

0

5

4

+ 81 other calls in file

ancestors.js

GitHub: elavoie/ssb-tokens

47
48
49
50
51
52
53
54
55
56

var util = require('./util')(ssb)

if (args['graph-easy']) {
  pull(
    pull.values(keys),
    pull.drain(function (k) {
      if (Object.keys(tangle[k]).length > 0) 
        Object.keys(tangle[k]).forEach(function (k2) {
          var label = tangle[k][k2] || 'source'

0

4

2

+ 315 other calls in file

index.js

GitHub: elavoie/ssb-tokens

482
483
484
485
486
487
488
489
490
491
  )
}

// Get and check all sources
pull(
  pull.values(op.sources),
  pull.asyncMap(get),
  pull.asyncMap((src, cb) => {
    var sId = src.msg.key
    var sOp = src.msg.value.content

0

4

2

+ 349 other calls in file

list.js

GitHub: elavoie/ssb-tokens

23
24
25
26
27
28
29
30
31
32
if (typeof args['alias-prefix'] !== "string")
  return cb(new Error("Invalid alias-prefix " + args["alias-prefix"] +
                      ", expected a string"))

list = pull(
  pull.values(ids),
  pull.asyncMap(function (id, cb) {
    ssb.about.socialValue(
      { key: 'name', dest: id }, 
      (err, value) => {

0

4

2

+ 69 other calls in file

types.js

GitHub: elavoie/ssb-tokens

50
51
52
53
54
55
56
57
58
59
  return cb(new Error("Non-unique match, found " +
                      Object.keys(types).length + 
                      " results"))

pull(
  pull.values(types),
  pull.asyncMap(function (tok, cb) {
    ssb.about.socialValue(
      { key: 'name', dest: tok.author}, function (err, name) {
        tok.author = { 

0

4

2

+ 69 other calls in file

add.js

GitHub: Paratii-Video/js-ipfs

37
38
39
40
41
42
43
44
45
46
}

function addPipeline (index, addStream, list, wrapWithDirectory) {
  pull(
    zip(
      pull.values(list),
      pull(
        pull.values(list),
        paramap(fs.stat.bind(fs), 50)
      )

0

3

3

+ 7 other calls in file

test.js

GitHub: regular/flumeview-level-transform

29
30
31
32
33
34
35
36
37
38
  })
}

sv.since.once( ()=>{
  pull(
    pull.values([{
      keys: [1],
      seq: 0,
      value: {foo: 'bar'}
    }]),

0

1

0

pull-resume.js

GitHub: DiegoT2k/provasocial

22
23
24
25
26
27
28
29
30
31
  filterMap
),

pull(
  // send truncated marker for resuming search
  pull.values([marker]),

  // don't emit the resume if we're at the end of the stream
  pull.filter(() => count === limit)
)

0

0

1

+ 5 other calls in file

muas_node.js

GitHub: tobed1995/cal-poly-muas-coin

55
56
57
58
59
60
61
62
63
64
self.dialProtocol(peer, '/add_unverified_transaction', function (err, conn) {
    if (err) {
        return
    }
    pull(
        pull.values([JSON.stringify(transaction)]),
        conn
    )

});

0

0

2

+ 4 other calls in file

transaction_pool.js

GitHub: tobed1995/cal-poly-muas-coin

85
86
87
88
89
90
91
92
93
    )
});

self.node.handle('/get_random_transaction', (protocol, conn) => {
    pull(
        pull.values(JSON.stringify(self.get_random_transaction())),
        conn
    )
});

0

0

2