;; Benchmark: 2.1us
;; Benchmark-Repeat: 921
;; Output: PipelineNode[last: Some(110.45243843391206)]

(do
  (def src1 (create-random-ohlc 42 3))
  
  (def combined 
    (pipe [src1]
      (fn [t1]
        (.close t1)
      )
    )
  )

  (def my_indicator
    (pipe [combined]
      (fn [close_price]
        (+ close_price 10.0)
      )
    )
  )
  
  my_indicator
)