Packages

ewe

0.7.0
4.0.1 4.0.0 3.0.8 3.0.7 3.0.6 3.0.5 3.0.4 3.0.3 3.0.2 3.0.1 3.0.0 2.1.3 2.1.2 2.1.1 2.1.0 2.0.3 2.0.2 2.0.1 2.0.0 1.0.1 1.0.0 1.0.0-rc2 1.0.0-rc1 0.10.0 0.9.0 0.8.1 0.8.0 0.7.0 0.6.0 0.5.0 0.4.0 0.3.0 0.2.0 0.1.0 0.0.2 0.0.1

🐑 a fluffy Gleam web server

Security advisory: This version has known vulnerabilities. View advisories
HexDocs

Current section

Files

Jump to
Readme
36 Versions
6 Dependencies
Dependants
3 Advisories
Files
Activity
ewe src ewe internal info.gleam
Raw

src/ewe/internal/info.gleam 

import gleam/erlang/process

import gleam/option

import gleam/otp/actor

import gleam/otp/supervision



pub type Message(a) {

  GetInfo(reply_to: process.Subject(Result(a, Nil)))

  SetInfo(info: a)

  Shutdown

}



pub fn start_worker(

  name: process.Name(Message(a)),

) -> supervision.ChildSpecification(process.Subject(Message(a))) {

  let info_actor =

    actor.new(option.None)

    |> actor.on_message(fn(state, msg) {

      case msg {

        GetInfo(reply_to) -> {

          actor.send(reply_to, option.to_result(state, Nil))

          actor.continue(state)

        }

        SetInfo(server) -> actor.continue(option.Some(server))

        Shutdown -> actor.stop()

      }

    })

    |> actor.named(name)

    |> actor.start()



  supervision.worker(fn() { info_actor })

}



pub fn get(subject: process.Subject(Message(a))) -> Result(a, Nil) {

  actor.call(subject, 10_000, GetInfo)

}



pub fn set(subject: process.Subject(Message(a)), info: a) -> Nil {

  actor.send(subject, SetInfo(info))

}