Class PipelineBasicsExample

java.lang.Object
com.streamconverter.examples.PipelineBasicsExample

public class PipelineBasicsExample extends Object
例1: IStreamCommand と StreamConverter の仕組み

StreamConverter のパイプライン処理の基本を示す。

この例で学べること:

  • IStreamCommand はラムダ式でも、AbstractStreamCommand を継承したクラスでも実装できる
  • StreamConverter.create(IStreamCommand...) に複数のコマンドを渡すと順番に接続されパイプラインになる
  • 各コマンドは別の仮想スレッドで並列実行される(ログのスレッド名で確認できる)
  • 前段コマンドの出力が後段コマンドの入力に自動的にバイト列として接続される

パイプライン構成(3段):

 [コマンド1: ラムダ実装]     各行の前後空白をトリム
          ↓
 [コマンド2: クラス実装]     各行を大文字に変換(AbstractStreamCommand 継承)
          ↓
 [コマンド3: 組み込みコマンド] 行末コードを LF に統一(LineEndingNormalizeCommand)