Packages

quickbeam

0.2.0
0.10.20 0.10.19 0.10.18 0.10.17 0.10.16 0.10.15 0.10.14 0.10.13 0.10.12 0.10.11 0.10.10 0.10.9 0.10.8 0.10.6 0.10.5 0.10.4 0.10.3 0.10.2 0.10.1 0.10.0 0.9.0 0.8.1 0.8.0 0.7.1 0.7.0 0.6.1 0.6.0 0.5.0 0.3.1 0.3.0 0.2.0 0.1.0

JavaScript runtime for the BEAM — Web APIs backed by OTP, native DOM, and a built-in TypeScript toolchain.

HexDocs

Current section

Files

Jump to
Readme
32 Versions
4 Dependencies
Dependants
Files
Activity
quickbeam lib quickbeam worker_api.ex
Raw

lib/quickbeam/worker_api.ex 

defmodule QuickBEAM.WorkerAPI do

  @moduledoc false



  @worker_bootstrap """

  globalThis.self = globalThis;

  const __parentPid = Beam.callSync("__worker_parent");

  self.postMessage = function(data) {

    Beam.send(__parentPid, ["__worker_msg", Beam.self(), data]);

  };

  Object.defineProperty(self, "onmessage", {

    set(handler) { Beam.onMessage(msg => {

      if (Array.isArray(msg) && msg[0] === "__worker_msg") {

        handler({ data: msg[1] });

      }

    }); },

    configurable: true,

  });

  """



  def spawn_worker([script], parent_pid) do

    {:ok, child} =

      QuickBEAM.start(

        handlers: %{

          "__worker_parent" => fn [] -> parent_pid end

        }

      )



    send(parent_pid, {:worker_monitor, child})



    QuickBEAM.eval(child, @worker_bootstrap)



    Task.start(fn ->

      case QuickBEAM.eval(child, script) do

        {:ok, _} -> :ok

        {:error, err} -> send(parent_pid, {:worker_error_from_child, child, err})

      end

    end)



    child

  end



  def terminate_worker([worker_pid]) do

    Task.start(fn -> QuickBEAM.stop(worker_pid) end)

    nil

  end

end