Packages

zenohex

0.1.0
0.9.1-beta.2 0.9.1-beta.1 0.9.0 0.8.0 0.7.2 0.7.1 0.7.0 0.6.2 0.6.1 0.5.1 0.5.0 0.4.0 0.3.2 0.3.1 0.3.0 0.2.0 0.1.5 0.1.3 0.1.0

Zenoh client library for elixir.

HexDocs

Current section

Files

Jump to
Readme
19 Versions
1 Dependency
Dependants
Files
Activity
zenohex lib nif_zenoh.ex
Raw

lib/nif_zenoh.ex 

defmodule NifZenoh do

  use Rustler, otp_app: :zenohex, crate: :nifzenoh



  @type session() :: reference()

  @type publisher() :: reference()



  @spec zenoh_open :: session() | no_return()

  def zenoh_open(), do: :erlang.nif_error("NIF zenoh_open is not implemented")



  @spec session_declare_publisher(session(), charlist()) :: {:ok, publisher()}

  def session_declare_publisher(_session, _keyexpr),

    do: :erlang.nif_error("NIF session_declare_publisher is not implemented")



  @spec publisher_put_string(publisher(), charlist()) :: no_return()

  def publisher_put_string(_publisher, _value),

    do: :erlang.nif_error("NIF publisher_put is not implemented")



  @spec publisher_put_integer(publisher(), charlist()) :: no_return()

  def publisher_put_integer(_publisher, _value),

    do: :erlang.nif_error("NIF publisher_put is not implemented")



  @spec publisher_put_float(publisher(), charlist()) :: no_return()

  def publisher_put_float(_publisher, _value),

    do: :erlang.nif_error("NIF publisher_put is not implemented")



  @spec tester_pub(charlist(), charlist()) :: no_return()

  def tester_pub(_keyexpr, _value), do: :erlang.nif_error("NIF tester_pub is not implemented")



  @spec tester_sub(charlist()) :: no_return()

  def tester_sub(_keyexpr), do: :erlang.nif_error("NIF tester_sub is not implemented")



  @spec session_declare_subscriber(session(), charlist(), pid()) :: no_return()

  def session_declare_subscriber(_session, _keyexpr, _callbackpid),

    do: :erlang.nif_error("NIF session_declare_subscriber is not implemented")



  @spec session_declare_subscriber_wrapper(session(), charlist(), function()) :: no_return()

  def session_declare_subscriber_wrapper(session, keyexpr, callback) do

    pid = spawn(NifZenoh, :wait_message, [callback])



    session_declare_subscriber(session, keyexpr, pid)

  end



  def wait_message(callback) do

    receive do

      msg -> callback.(msg)

    end



    wait_message(callback)

  end

end