Adds periodic heartbeat markers while an upstream enumerable is silent.
The producer is pulled at most one event ahead so slow HTTP clients cannot cause unbounded buffering. Consumers render heartbeat markers as SSE comments.
Summary
Types
Functions
@spec wrap(Enumerable.t(), pos_integer()) :: Enumerable.t()