How to use the flatten function from pull-stream

index.js

GitHub: ssbc/jitdb

1565
1566
1567
1568
1569
1570
1571
1572
1573
1574
    recordStream = toPull(log.stream(opts))
  }

  return recordStream
}),
pull.flatten(),
pull.filter((record) => isValueOk([op], record.value)),
pull.through(() => {
  if (debugQuery.enabled)
    debugQuery(

6

48

8

index.js

GitHub: ssbc/ssb-tribes2

254
255
256
257
258
259
260
261
262
263
            return cb(null, source)
          })
        )
      })
    }),
    pull.flatten()
  )
}

function acceptInvite(groupId, cb) {

1

7

4

+ 65 other calls in file