Hi!

I'm trying to find out what the best way to do projections is in Onyx

i.e:considering two (or n) outputs

feed the last value by key to a subsequent processing step

(i.e, something like: http://riemann.io/api/riemann.streams.html#var-project in the riemann world)

The general approach you would use is the windowing functionality to hold your state, and then trigger/emit to a downstream task

ok, so around section 6 of the learn-onyx challenges then

That’d be a good place to start. We need to update learn-onyx to cover :trigger/emit http://www.onyxplatform.org/docs/cheat-sheet/latest/#trigger-entry/:trigger/emit though. Currently it only demonstrates :trigger/sync which fires a function to cause side effects.

ack, thanks