;; Skip: data output to stdout
(do
  (def EURUSD (create-m1-stream "EURUSD" (date "2020-01-03 09:30:00") (date "2020-01-03 13:30:00")))
  (def GER40 (create-m1-stream "GER40" (date "2020-01-03 09:30:00") (date "2020-01-03 13:30:00")))

  ;; Sink: print returns void, so nothing is propagated downstream

  (def cnt 1)
  (def gs (series 2))

  (pipe [EURUSD GER40]
    (fn [eu ge]
      (do
        (def dax (.close ge))
        (push gs dax)
        (def eur (- dax (gs 1)))
        (print cnt ": dax=" eur " (" (/ eur (.close eu)) "$)" )
        (assign cnt (+ cnt 1))
      )
    )
  )
)