Clojurians Log v2

Anyone have an example of how I could work with an incoming websocket stream as a missionary flow by implementing a message handler passed to the websocket constructor?

ie

(make-websocket 
  :on-receive 
  (fn [msg] 
    ;;..how to put msg on a flow?
  ))

if your ws implementation is non backpressured and callback based, try observe

Thank you, I'll give that a shot