Class SynchronizedParallelIterable<T>

    • Constructor Detail

      • SynchronizedParallelIterable

        public SynchronizedParallelIterable​(ParallelIterable<T> delegate,
                                            java.lang.Object lock)
    • Method Detail

      • selectInstancesOf

        public <S> ParallelIterable<S> selectInstancesOf​(java.lang.Class<S> clazz)
      • collect

        public <V> ParallelIterable<V> collect​(Function<? super T,​? extends V> function)
        Description copied from interface: ParallelIterable
        Creates a parallel iterable for collecting elements from the current iterable.
      • collectWith

        public <P,​V> ParallelIterable<V> collectWith​(Function2<? super T,​? super P,​? extends V> function,
                                                           P parameter)
      • collectIf

        public <V> ParallelIterable<V> collectIf​(Predicate<? super T> predicate,
                                                 Function<? super T,​? extends V> function)
        Description copied from interface: ParallelIterable
        Creates a parallel iterable for selecting and collecting elements from the current iterable.
      • flatCollect

        public <V> ParallelIterable<V> flatCollect​(Function<? super T,​? extends java.lang.Iterable<V>> function)
        Description copied from interface: ParallelIterable
        Creates a parallel flattening iterable for the current iterable.
      • groupBy

        public <V> Multimap<V,​T> groupBy​(Function<? super T,​? extends V> function)
      • groupByEach

        public <V> Multimap<V,​T> groupByEach​(Function<? super T,​? extends java.lang.Iterable<V>> function)