Filters

自己完結しており通常ステートレスな機能で、1つのタスクのみを行う。

複数タスクを行いたければ複数のフィルターを用いる

4種類のフィルターがある

Producer

プロセスの起点となり、outbound only. sourceとも呼ばれる

Transformer

inputを受け取り、(optionally)変換を加えてoutbound pipeに流す

関数プログラマはこれをmapと呼ぶこともある

Tester

inputを受け取り何らかの基準でテストをして(optionally)outboundに流す

reduceとも呼ぶ

Consumer

フローの終着点。データベースに永続化したりユーザに表示したりする