Specs

new(Map.t(), (error(), retry() -> any()), pos_integer()) :: Enumerable.t()

Build a stream resource from a facebook paginated response with a custom define error handler and a maximum of retries

The user defined error handler can be used to log errors, delay next retry, raise an exception, etc. The default error handler sleeps 1 second between retries.

Examples

iex> stream = Facebook.page_feed(:feed, "CocaColaMx", "<Your Token>", "id,name") |> Facebook.Stream.new
iex> stream |> Stream.filter(fn(name) -> name == "Coca Cola" end) |> Stream.take(100) |> Enum.to_list

Custom error handler with linear backoff

iex> feed = Facebook.page_feed(:feed, "CocaColaMx", "<Your Token>", 25, "id,name")
iex> stream = Facebook.Stream.new(feed, fn(error, retry) -> Process.sleep(retry*500) end)
iex> stream |> Stream.filter(fn(name) -> name == "Coca Cola" end) |> Stream.take(100) |> Enum.to_list