flatten.rs - source

Files

adler32

ansi_term

ansi.rs debug.rs difference.rs display.rs lib.rs style.rs windows.rs write.rs

atty

backtrace

backtrace

libunwind.rs mod.rs

symbolize

dladdr.rs libbacktrace.rs mod.rs

capture.rs lib.rs print.rs types.rs

backtrace_sys

bitflags

byteorder

cfg_if

clap

color_quant

crossbeam_deque

crossbeam_epoch

sync

list.rs mod.rs queue.rs

atomic.rs collector.rs default.rs deferred.rs epoch.rs guard.rs internal.rs lib.rs

crossbeam_queue

array_queue.rs err.rs lib.rs seg_queue.rs

crossbeam_utils

atomic

atomic_cell.rs consume.rs mod.rs seq_lock.rs

sync

mod.rs parker.rs sharded_lock.rs wait_group.rs

backoff.rs cache_padded.rs lib.rs thread.rs

deflate

either

event_loop

failure

backtrace

internal.rs mod.rs

error

error_impl.rs mod.rs

as_fail.rs box_std.rs compat.rs context.rs error_message.rs lib.rs macros.rs result_ext.rs sync_failure.rs

failure_derive

float

fnv

gif

reader

decoder.rs mod.rs

common.rs encoder.rs lib.rs traits.rs

gl

graphics

image

inflate

checksum.rs lib.rs reader.rs utils.rs writer.rs

input

after_render.rs button.rs close.rs controller.rs cursor.rs focus.rs generic_event.rs idle.rs keyboard.rs lib.rs mouse.rs render.rs resize.rs text.rs touch.rs update.rs

interpolation

ease.rs lib.rs spatial.rs

jpeg_decoder

worker

immediate.rs mod.rs threaded.rs

decoder.rs error.rs huffman.rs idct.rs lib.rs marker.rs parser.rs upsampler.rs

lazy_static

inline_lazy.rs lib.rs

libc

unix

linux_like

linux

gnu

b64

x86_64

align.rs mod.rs not_x32.rs

align.rs mod.rs

align.rs mod.rs

align.rs mod.rs

fixed_width_ints.rs lib.rs macros.rs

lzw

bitstream.rs lib.rs lzw.rs

memoffset

lib.rs offset_of.rs span_of.rs

num

num_cpus

num_derive

num_integer

lib.rs roots.rs

num_iter

num_rational

num_traits

ops

checked.rs inv.rs mod.rs mul_add.rs saturating.rs wrapping.rs

bounds.rs cast.rs float.rs identities.rs int.rs lib.rs macros.rs pow.rs real.rs sign.rs

opengl_graphics

back_end.rs draw_state.rs error.rs lib.rs shader_uniforms.rs shader_utils.rs texture.rs

piston

png

decoder

mod.rs stream.rs

chunk.rs common.rs crc.rs encoder.rs filter.rs lib.rs traits.rs utils.rs

rand

rayon

delegate.rs lib.rs math.rs option.rs par_either.rs prelude.rs private.rs range.rs range_inclusive.rs result.rs split_producer.rs str.rs vec.rs

rayon_core

compile_fail

mod.rs quicksort_race1.rs quicksort_race2.rs quicksort_race3.rs rc_return.rs rc_upvar.rs scope_join_bad.rs

join

scope

sleep

spawn

thread_pool

job.rs latch.rs lib.rs log.rs private.rs registry.rs unwind.rs util.rs

read_color

rustc_demangle

legacy.rs lib.rs v0.rs

scoped_threadpool

scopeguard

sdl2

sdl2_sys

sdl2_window

serde

de

from_primitive.rs ignored_any.rs impls.rs mod.rs utf8.rs value.rs

private

de.rs macros.rs mod.rs ser.rs

ser

impls.rs impossible.rs mod.rs

export.rs integer128.rs lib.rs macros.rs

serde_derive

internals

ast.rs attr.rs case.rs check.rs ctxt.rs mod.rs symbol.rs

bound.rs de.rs dummy.rs fragment.rs lib.rs pretend.rs ser.rs try.rs

shader_version

glsl.rs lib.rs opengl.rs

shaders_graphics2d

colored

textured

sorting_visualization

algorithms

all.rs bubble.rs cocktail.rs cycle.rs gnome.rs heap.rs insertion.rs merge.rs mod.rs quicksort.rs selection.rs shellsort.rs

app.rs array.rs cli.rs main.rs state.rs

strsim

synstructure

lib.rs macros.rs

texture

textwrap

indentation.rs lib.rs splitting.rs

tiff

decoder

ifd.rs mod.rs stream.rs

error.rs lib.rs

unicode_width

lib.rs tables.rs

vec_map

vecmath

lib.rs traits.rs

viewport

window

lib.rs no_window.rs

use super::plumbing::*;
use super::*;

/// `Flatten` turns each element to an iterator, then flattens these iterators
/// together. This struct is created by the [`flatten()`] method on
/// [`ParallelIterator`].
///
/// [`flatten()`]: trait.ParallelIterator.html#method.flatten
/// [`ParallelIterator`]: trait.ParallelIterator.html
#[must_use = "iterator adaptors are lazy and do nothing unless consumed"]
#[derive(Debug, Clone)]
pub struct Flatten<I: ParallelIterator> {
    base: I,
}

impl<I, PI> Flatten<I>
where
    I: ParallelIterator<Item = PI>,
    PI: IntoParallelIterator + Send,
{
    /// Create a new `Flatten` iterator.
    pub(super) fn new(base: I) -> Self {
        Flatten { base }
    }
}

impl<I, PI> ParallelIterator for Flatten<I>
where
    I: ParallelIterator<Item = PI>,
    PI: IntoParallelIterator + Send,
{
    type Item = PI::Item;

    fn drive_unindexed<C>(self, consumer: C) -> C::Result
    where
        C: UnindexedConsumer<Self::Item>,
    {
        fn id<T>(x: T) -> T {
            x
        }

        self.base.flat_map(id).drive_unindexed(consumer)
    }
}