Flow-based programming (FBP) / communicating sequential processes (CSP) in Ruby