const rx = proteo({
  when: prop => prop === "subscribe",
  value: prop => next => next(6)
})
 
rx.Observable.from([1, 2])
  .map(double)
  .reduce(add)
  .subscribe(n => console.log(n)) // 6
 
console.log(rx.calls.get())
/*
 
{
  map: [[double]],
  reduce: [[add]]
}
 
*/

const res = proteo({
  when: prop => prop === "send",
  value: prop => data => data
})
 
res.status(200).send({ data: true })
 
console.log(rx.calls.get())
/*
{
  status: [[200]],
  send: [[{ data: true }]]
}
*/

 
const api = proteo({
  when: (prop) => prop === "finish" // condition to stop chain
  value: () => true // value returned
  store: "customName" // name for store calls
})
 
api.a.b().c.finish // true
api.customName.get() // get calla
api.customName.clear() // clear calls