How to use the pull function from pull-stream

Find comprehensive JavaScript pull-stream.pull code examples handpicked from public code repositorys.

355
356
357
358
359
360
361
362
363
364
let decoder
let cbp

source.first = () => {
        let result
        return pull(
                source,
                drain((i) => {
                        result = i
                        return false
fork icon3
star icon0
watch icon4

+ 5 other calls in file

27
28
29
30
31
32
33
34
35
36
37
test('Write', (t) => {
	t.test((t) => {
		t.plan(2)


		const id = new ObjectId()
		const write = pull(values(nonceChunks), mfs.write(id)).then((err) =>
			t.notOk(err)
		)
		join(id, write, mfs.read).then((file) => t.ok(file))
	})
fork icon1
star icon0
watch icon0

+ 39 other calls in file

2919
2920
2921
2922
2923
2924
2925
2926
2927
2928
var ref = args
args = null

// Prioritize common case of small number of pulls.
switch (length) {
case 1: return pull(read, ref[0])
case 2: return pull(read, ref[0], ref[1])
case 3: return pull(read, ref[0], ref[1], ref[2])
case 4: return pull(read, ref[0], ref[1], ref[2], ref[3])
default:
fork icon0
star icon0
watch icon5

+ 6 other calls in file

3
4
5
6
7
8
9
10
11
12
13
const {pull, through, values, error} = require('pull-stream')
const some = require('./')


test((t) => {
	t.plan(2)
	const stream = pull(
		values([1, 2, 3]),
		some((x) => x > 2)
	)

fork icon0
star icon0
watch icon0