Java 8 - 退屈な収集方法を省略

Question

Java 8ストリームAPIは非常に素晴らしい機能であり、私は絶対にそれを好きです。私の神経を邪魔することの1つは、コレクションとして入力してコレクションとして出力したい時間の90％です。結果は、私はすべての時間stream()とcollect()メソッドを呼び出す必要があります：（？C＃でのようなlinqを）

collection.stream().filter(p->p.isCorrect()).collect(Collectors.toList()); 

は私がストリームをスキップして、直接コレクションを操作してみましょうであろう任意のJava APIがあります：

Collection#removeIf(Predicate)を使用して

collection.filter(p->p.isCorrect) 

Answer 1

コレクションを操作したい場合は、をクリックしてください。

例（10人の最初のVIP顧客のIDを取得）：

FluentIterable 
     .from(customers) 
     .filter(customer -> customer.isVIP()) 
     .transform(Client::getId) 
     .limit(10); 

Answer 2

はい、：

は、与えられた述語を満たすこのコレクションのすべての要素を削除します。

これは、指定されたコレクションを変更し、新しいコレクションを返さないことに注意してください。しかし、あなたはコレクションのコピーを作成し、それを変更することができます。

public static <E> Collection<E> getFilteredCollection(Collection<E> unfiltered, 
                 Predicate<? super E> filter) { 
    List<E> copyList = new ArrayList<>(unfiltered); 

    // removeIf takes the negation of filter 
    copyList.removeIf(e -> { return !filter.test(e);}); 

    return copyList; 
} 

しかし@Holgerはコメントで示唆するように、あなたのコードでこのユーティリティメソッドを定義することを選択し、どこでもそれを使用する場合は、取得する必要があります。また、述語はフィルタとして機能するように否定する必要があることに注意してくださいフィルタリングされたコレクションを作成し、そのユーティリティの collectメソッドへの呼び出しを委譲します。あなたの発信者コードはより簡潔になります。

public static <E> Collection<E> getFilteredCollection(Collection<E> unfiltered, 
                 Predicate<? super E> filter) { 
    return unfiltered.stream() 
        .filter(filter) 
        .collect(Collectors.toList()); 
} 

Answer 3

あなたが元のコレクションを変更することなく、フィルタビューが必要な場合は、グアバのCollections2.filter()を検討してください。

Answer 4

ストリームは、明確に定義されたアーキテクチャを持っています。which you can read a lot about。この道を始める前にそれについて読んでみてください。

しかし、コレクションを実装しないと、そのコードを包括する同様のストリームインターフェイスが実装されます。

次に、あなたのユースケースについていくつかのトリッキーな仮定を行うことができます。あなたはまだコレクションインターフェイスからストリームを開くことができますが、あなたはまっすぐにジャンプすることもできますし、その内側で私が想定しているストリームの開始を処理することができます。

streamableCollection cs = new streamableCollection(); 
    cs.filter(); 
    cs.stream(); 

あなたのIDEは、すべてを実装することができます。すべてをデフォルトの実装に戻してください。

Answer 5

あなたは、これは不変性を維持しながら、もう少し簡単であるという利点を持っているStreamEx

StreamEx.of(collection).filter(PClass::isCorrect).toList(); 

を使って好きかもしれません。

Answer 6

あなたはグアバライブラリから、これを試してみてください。 Streamのアプローチよりもちょっと混乱しているようです。

ImmutableList.copyOf(Iterables.filter(collection, MyClass::isCorrect)); 

この技術についての説明は、Google Collections (Guava Libraries): ImmutableSet/List/Map and Filteringを参照してください。

Answer 7

私はまた、ストリームAPIは良いと思うが、短い操作では冗長だと思う。私はいくつかのプロジェクトでこれらのユーティリティメソッドを使用しました：

import java.util.List; 
import java.util.function.Function; 
import java.util.function.Predicate; 
import java.util.stream.Collectors; 
import java.util.stream.Stream; 

public class Functions { 

    public static <T,V> List<V> map(final List<T> in, final Function<T, V> function) { 
     return in == null ? null : map(in.stream(), function); 
    } 

    public static <T,V> List<V> map(final Stream<T> in, final Function<T, V> function) { 
     return in == null ? null : in 
      .map(function) 
      .collect(Collectors.toList()); 
    } 

    public static <T> List<T> filter(final List<T> in, final Predicate<T> predicate) { 
     return in == null ? null : filter(in.stream(), predicate); 
    } 

    public static <T> List<T> filter(final Stream<T> in, final Predicate<T> predicate) { 
     return in == null ? null : in 
      .filter(predicate) 
      .collect(Collectors.toList()); 
    } 
} 

List<String> wrapped = Functions.map(myList, each -> "[" + each + "]"); 

通常、メソッドも静的にインポートします。

Answer 8

はい、Java 8のストリームの冗長性に対応するライブラリがいくつかあります。不完全なリスト：

• jOOL
• javaslang
• StreamEx

私の好みはjOOLとなります。私は最後のプロジェクトでそれを使ってきました。私が知っている他の人たちが、私は本当に使っていないので、あなたに印象を与えることはできません。

jOOLとあなたの例では、次のようになります。

Seq.seq(collection).filter(p->p.isCorrect()).toList(); 

Answer 9

サードパーティのライブラリを使用することに開いている場合は、コレクションの下に直接利用できる豊富なAPIを持っているEclipse Collectionsを使用することができます。あなたの例はEclipse Collectionsで以下のように書くことができます。

collection.select(p->p.isCorrect) 
collection.select(MyClass::isCorrect) 

注：私はEclipse Collectionsのコミッターです。

Answer 10

cyclops-reactにはいくつかのオプションがあります。

我々は怠惰な拡張コレクション

CollectionX<String> collection = ListX.of("hello","world"); 
    CollectionX<String> filtered = collection.filter(p->p.isCorrect()); 

、可変不変かつ持続的な拡張コレクションのサポートがあるのを利用することができます。コレクションの機能操作は遅延（すなわち再生可能なストリームのように振る舞う）であり、最初のアクセス時にのみ実現される。

我々は `[開示、私は反応しサイクロプスのリード開発者です]