4
Stream#flatMap(...)が使えるかもしれません。
import java.util.*;
import java.util.stream.*;
import java.util.function.*;
public class StreamTest {
public static void main(String... args) {
List<String> innerA = Arrays.asList("a", "a", "a");
List<String> innerB = Arrays.asList("b", "b", "b");
List<String> innerC = Arrays.asList("c", "c", "...
2
実際には途中の処理順やパフォーマンス等、何か差異があるでしょうか。
逐次(sequential)ストリームとなっているため、両パターンとも処理順序は同一です。
(有意差はないと予想しますが、)パフォーマンス比較は実環境にて計測してください。
Streamの書き方としてより適切なのはどちら(あるいはどちらでもない)か、というのも知りたいです。
正解のない問いだと思いますが、個人的には パターン2 の方が好ましいと考えます。
パターン1: .map(Parent::getChildren).flatMap(List::stream)
パターン2: .flatMap(p -> p.getChildren().stream())
論理的には「子Listのflatten処理」...
2
streamではAtomicBooleanにしろと言われました。
(コンパイルエラーとしては "ラムダ式から参照されるローカル変数は、finalまたは事実上のfinalである必要があります" なので、ここからAtomicBooleanに至るまでには少し飛躍があるように思われますが、疑問の関心には含まれていないようなので端折ります)
簡単に言うと、ストリーム操作はマルチスレッドで実行される可能性を考慮して実装する必要があるからです。
Stream#forEach()の説明で次のように表現されています:
与えられた任意の要素に対し、ライブラリが選択した任意のタイミングで任意のスレッド内でアクションが実行される可能性があります。 アクションが共有状態にアクセスする場合、...
1
_itemsControllerにはデータしか流れないため、状態までは分からないですね。
そのため状態も分かるようにするため、状態用のクラスを用意し、データはこのクラスに内包させる方法はどうでしょうか。
状態用のクラス
abstract class FetchState {}
class Fetching extends FetchState {}
class Fetched extends FetchState {
Fetched({this.entryList});
/// 取得したデータ
List<Entry> entryList;
}
データ取得の実装
loadEntries() async {
_itemsController.add(Fetching());
...
1
方法: ローカルのプロセス間通信で匿名パイプを使用する
本来はプロセス間通信用ですが、AnonymousPipeServerStreamへ書き込んで、AnonymousPipeClientStreamから読み出すというのはどうでしょうか?
1
HLS(HTTP Live Streaming)はPull型の映像ストリーミング・プロトコルですから、再生開始位置の判断・決定はクライアントサイド実装に依存します。HLSクライアントでライブ配信セッションを再生する場合、配信遅延を小さくする方が好ましいため、一般的には最も新しいメディアセグメントから再生開始します。
サーバサイドからみたHLSライブ配信セッションでは、ディスク容量の浪費を防ぐため、古いメディアセグメントファイルから自動削除していく運用が一般的です。ライブ配信中のコンテンツを、VoD(Video on Demand)的にコンテンツ先頭から再生したい場合、このようなメディアセグメント自動削除を無効化する必要があります。
所望の動作を実現するには、2つの方針が考えられます。
...
1
そもそも、peek()中間操作は主にデバッグ用途(中間値の確認)として提供されるものです。Stream処理ロジックの一部として使うことは推奨されません。ストリーム処理中の副作用に関する注意も確認してください。
またsorted()中間操作による堰き止めに頼るのもお勧めできません。例示コードでは、ソート処理には全要素値バッファリングが必要なので、結果的に期待する動作となっています。しかしSpliteratorがSORTED特性をもつ場合、sorted()中間操作は"何もしない"と考えられます。
仰るような動作をさせたければ、単にストリームを2回生成すべきだと思います。(peekの使用はあえて残しましたが、本来は全体処理を見直すべきです。)
IntStream stream = IntStream.of(1, ...
1
ちょっと変わった方法ですがこんなのもどうですか?
Optional<List<String>> innerABC = outer.stream()
.reduce((s1, s2) -> concat(s1.stream(), s2.stream())
.collect(Collectors.toList()));
if(innerABC.isPresent()){
System.out.println(innerABC.get());
}
上位に投票された、最小文字数のコミュニティ wiki 以外の回答のみが対象となります