;; Skip: data output to stdout
(do
  (def EURUSD (create-m1-stream "EURUSD" (date "2020-01-03 09:30:00") (date "2020-01-03 17:30:00")))
  (def GER40 (create-m1-stream "GER40" (date "2020-01-03 09:30:00") (date "2020-01-03 17: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))
      )
    )
  )

  ; TODO: IDEE - pipe mit automatischer Value-Akkumulation: pipe <lookback> <inputs>

  (pipe 2 [EURUSD GER40]
    (fn [eu ge]
      (do
        ; eu und ge werden hier zu Serien mit lookback 2
        (def dax (.close (ge 0)))
        (push gs dax)
        (def eur (- dax (ge 1)))
        (print cnt ": dax=" eur " (" (/ eur (.close (eu 0))) "$)" )
        (assign cnt (+ cnt 1))
      )
    )
  )
)