Packages

puck

0.2.24
0.2.25 0.2.24 0.2.23 0.2.22 0.2.21 0.2.20 0.2.19 0.2.18 0.2.17 0.2.16 0.2.15 0.2.14 0.2.13 0.2.12 0.2.11 0.2.10 0.2.9 0.2.8 0.2.7 0.2.6 0.2.5 0.2.4 0.2.3 0.2.2 0.2.1 0.2.0 0.1.0

AI Agent primitives for Elixir.

HexDocs

Current section

Files

Jump to
Readme
27 Versions
12 Dependencies
Dependants
Files
Activity
puck lib puck sandbox runtime ndjson.ex
Raw

lib/puck/sandbox/runtime/ndjson.ex 

defmodule Puck.Sandbox.Runtime.NDJSON do

  @moduledoc false



  @doc """

  Transforms a stream of binary chunks into a stream of decoded JSON objects.



  Handles partial lines across chunk boundaries by buffering incomplete lines.

  """

  def stream(enum) do

    enum

    |> Stream.transform("", &parse_lines/2)

    |> Stream.reject(&(&1 == ""))

    |> Stream.map(&Jason.decode!/1)

  end



  defp parse_lines(chunk, buffer) do

    data = buffer <> chunk

    lines = String.split(data, "\n")

    {complete, [partial]} = Enum.split(lines, -1)

    {complete, partial}

  end

end