;; Benchmark: 1.4us
;; Benchmark-Repeat: 1423
;; Output: <StreamNode>

(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
)