Functions — github.com/NfNitLoop/pipeliner

CodeHub MCPcopy Create free account

hub / github.com/NfNitLoop/pipeliner / functions

Functions35 in github.com/NfNitLoop/pipeliner

⨍ Functions 35 ◇ Types & classes 11

↓ 11 callersFunctionnew

(builder: PipelineBuilder<I>, callable: F)

src/ordered/mod.rs:30

↓ 8 callersMethodwith_threads

(self, num_threads: usize)

↓ 7 callersMethodmap

Apply `callable` to items from the input Iterator and make them available via the output iterator. Note that the order of items in the output Iterato

↓ 3 callersMethodclone

src/unordered.rs:168

↓ 3 callersMethodordered_map

Like `map()`, but does some extra work to ensure that results in the output match the order of their inputs from the input Iterator. This requires a b

↓ 2 callersMethodclone

src/ordered/mod.rs:173

↓ 2 callersFunctionpropagate_panics

Wait for all threads to close. Panics if any of them panicked.

src/unordered.rs:75

↓ 2 callersMethodpropagate_panics

Makes panics that were experienced in the worker/producer threads visible on the consumer thread. Calling this function ends output -- we will wait fo

src/unordered.rs:66

↓ 2 callersMethodpropagate_panics

src/ordered/mod.rs:23

↓ 2 callersMethodsend

(&self, item: T)

src/panic_guard.rs:19

↓ 2 callersMethodsend

Sends an item, consuming the sender. Never blocks. Does not error or panic if the receiver is already closed. (You can only ever send one thing.)

src/ordered/promise.rs:21

↓ 1 callersMethodnum_threads

Set how many worker threads should be used to perform this work. A value of 0 is interpreted as 1.

↓ 1 callersFunctionpanic_msg_from

Try to reconstruct a panic message from the original: Thanks to kimundi on #rust-beginners for helping me sort this out. :)

src/unordered.rs:91

↓ 1 callersMethodreceive

Block waiting for the value. May return an error if the sender was dropped before a value was sent.

src/ordered/promise.rs:41

↓ 1 callersMethodresult

src/unordered.rs:196

Functionbasic_test

Functionbasic_test_ordered

src/tests.rs:24

src/panic_guard.rs:60

Create a new promise sender/receiver for sending a single value to aonther waiting thread.

src/ordered/promise.rs:7

src/panic_guard.rs:15

(builder: PipelineBuilder<I>, callable: F)

src/unordered.rs:23

Iterates through executor results. # Panics # Note, this call will panic if any of the worker threads panicked. This is because, in that case, you ca

src/unordered.rs:113

Iterates through executor results. # Panics # Note, this call will panic if any of the worker threads panicked. This is because, in that case, you ca

src/ordered/mod.rs:81

Methodout_buffer

Set how many output values to cache. The default, 0, results in synchronous output. Note that in effect each thread caches its output as it waits to s

Functionparallel_test

src/tests.rs:74

src/tests.rs:92

src/tests.rs:98

Functionsending_and_receiving

(b: &mut Bencher)

benches/benchmarks.rs:14

Functionsending_and_receiving_ordered

(b: &mut Bencher)

benches/benchmarks.rs:30

Functionserial_test

src/tests.rs:83

Functiontest_panic

src/tests.rs:37

Functiontest_panic_ordered

src/tests.rs:56

src/unordered.rs:156

(iterator: I, chan: crossbeam_channel::Sender<promise::Receiver<Out>>)

src/ordered/mod.rs:126