Filters
自己完結しており通常ステートレスな機能で、1つのタスクのみを行う。 複数タスクを行いたければ複数のフィルターを用いる
4種類のフィルターがある
Producer
プロセスの起点となり、outbound only. sourceとも呼ばれる
Transformer
inputを受け取り、(optionally)変換を加えてoutbound pipeに流す
関数プログラマはこれをmapと呼ぶこともある
Tester
inputを受け取り何らかの基準でテストをして(optionally)outboundに流す
reduceとも呼ぶ
Consumer
フローの終着点。データベースに永続化したりユーザに表示したりする