pump(
  stream_name :: binary(),
  records :: [binary()],
  delimiter :: binary(),
  opts :: keyword()
) :: {:ok, any()}