ExLTTB.Stream example

ex_lttb_stream.exs

input_stream =
  Stream.iterate(%{x: 0, y: :random.uniform() * 100}, fn %{x: x} ->
    %{x: x + 1, y: :random.uniform() * 100}
  end)
  
# Take 20 samples output samples after downsampling by 2.3
# The 20 output samples will correspond to ~ 20 * 2.3 input samples
output_samples =
  ExLTTB.Stream.downsample(input_stream, 2.3)
  |> Enum.take(20)