stream --> | processor 1| ---> | processor 2| ----> .etc
  sub processor_1 (@) {  }
  sub processor_2 (@) { }