lulu 0.0.721

A mini lua runtime
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83



class!
@into_collectible("collect")
InterprocSocket(addr), {
  init(addr){
    self.__on_send = {}
    self.__on_recv = {}
    self.__recv = function() end
    self.__host = interproc.listen(addr, function(data)
      for _, r in ipairs(self.__on_recv) do
        local res = r(data)
        if res then
          data = res
        end
      end
      self.__recv(data)
    end)
  }

  on_recv(fn){
    table.insert(self.__on_recv, fn)
    return self
  }
  on_send(fn){
    table.insert(self.__on_send, fn)
    return self
  }

  listen(fn){
    self.__recv = fn
    return self
  }

  with(ext){
    if type(ext) == "table" then
      self:on_recv(ext.on_recv)
      self:on_send(ext.on_send)
    end
    return self
  }

  send(data){
    for _, r in ipairs(self.__on_send) do
      local res = r(data)
      if res then
        data = res
      end
    end
    if type(data) ~= "userdata" then
      data = ByteArray(tostring(data))
    end
    interproc.send(self.addr, data)
  }

  stop(){
    self.__host:stop()
    interproc.send(self.addr, ByteArray(""))
  }
}

interproc.JSON = {
  on_send = function(data) return serde.json.encode(data) end,
  on_recv = function(data) return serde.json.decode(data:to_string()) end,
}

interproc.String = {
  on_send = function(data) return ByteArray(data) end,
  on_recv = function(data) return data:to_string() end,
}

interproc.Serialize = {
  on_send = function(data) if data.serialize then return data:serialize() else return data end end,
}

interproc.Deserialize = function(type) return {
  on_recv = function(data) try_catch!{
    return type:deserialize(data:to_string())
  }, {
    return data
  }
  return err end,
} end