Simply use programs in kefirs flatMap.
Via npm
npm install kefir-process
Create a processor and pass it to flatMap:
import {createProcess} from 'kefir-process'
Kefir.sequentially(100, ['Kefir', 'Process', 'App'])
.flatMap(createProcess('grep', ['Process']))