Specs

receive_insert(pid(), Range.t() | [integer()] | PelemayFp.ParallelSplitter.t()) ::
  PelemayFp.Merger.t()

Receives a given consecutive list of tuples of a Range, count and a list, or an exit or dying message from the monitored process and merges it into a result, and send it.

Specs

receive_insert_fun(
  pid(),
  [PelemayFp.ParallelSplitter.t()],
  (non_neg_integer() -> list())
) :: PelemayFp.Merger.t()

Receives a given consecutive list of tuples of a Range, count and a list, or an exit or dying message from the monitored process and merges it into a result, and send it.

When the monitored process dies abnormally, the fallback function will be invoked.