grammy

Types

Builder

pub type Builder(user_state, user_message) {
  Builder(
    on_init: fn() ->
      #(user_state, Option(Selector(user_message))),
    port: Int,
    handler: Handler(user_state, user_message),
  )
}

Constructors

Builder(
  on_init: fn() -> #(user_state, Option(Selector(user_message))),
  port: Int,
  handler: Handler(user_state, user_message),
)

Connection

opaque </>

pub opaque type Connection

Handler

</>

pub type Handler(user_state, user_message) =
  fn(Message(user_message), Connection, user_state) ->
    actor.Next(user_message, user_state)

Message

</>

pub type Message(user_message) {
  User(message: user_message)
  Packet(ip_address: IpAddress, port: Int, data: BitArray)
}

Constructors

```
User(message: user_message)
```

Packet(ip_address: IpAddress, port: Int, data: BitArray)

Socket

</>

pub type Socket

UdpServer

opaque </>

pub opaque type UdpServer

Functions

get_supervisor

</>

pub fn get_supervisor(server: UdpServer) -> Subject(Message)

ip_address_to_string

</>

pub fn ip_address_to_string(ip: #(Int, Int, Int, Int)) -> String

new

</>

pub fn new(
  init init: fn() -> #(a, Option(Selector(b))),
  handler handler: fn(Message(b), Connection, a) -> Next(b, a),
) -> Builder(a, b)

port

</>

pub fn port(builder: Builder(a, b), port: Int) -> Builder(a, b)

send_to

</>

pub fn send_to(
  connection: Connection,
  address: #(Int, Int, Int, Int),
  port: Int,
  data: BytesBuilder,
) -> Result(Nil, Nil)

start

</>

pub fn start(
  builder: Builder(a, b),
) -> Result(UdpServer, StartError)

udp_send

</>

pub fn udp_send(
  socket: Socket,
  host: #(Int, Int, Int, Int),
  port: Int,
  packet: BytesBuilder,
) -> Result(Nil, Nil)