lori's Introduction

Lori

Pony TCP classes reimagined.

Status

This is an experimental project and shouldn't be used in a production environment.

Installation

Install corral
corral add github.com/seantallen/lori.git
corral fetch to fetch your dependencies
use "lori" to include this package
corral run -- ponyc to compile your application

Example

Server

actor Main
  new create(env: Env) =>
    try
      let auth = TCPListenAuth(env.root as AmbientAuth)
      TCPListener(auth, None, {():None => None} val)
      .> on(DATA, {(c: TCPConnection ref, d: Array[U8] iso) => c.send(consume d) })
      .> listen("0.0.0.0", 7669)
    end

Client

actor Main
  new create(env: Env) =>
    try
      let auth = TCPConnectAuth(env.root as AmbientAuth)
      TCPConnection(auth, None)
      .> on(CONN, {(self: TCPConnection ref) =>self.send("Hello!")})
      .> on(DATA, {(self: TCPConnection ref, d: Array[U8] iso) => self.log(consume d) })
      .> start("127.0.0.1", 7669, "localhost")
    end

Ping-Pong

actor Main
  new create(env: Env) =>
    try
      // auth
      let listen_auth = TCPListenAuth(env.root as AmbientAuth)
      let conn_auth = TCPConnectAuth(env.root as AmbientAuth)

      // server
      TCPListener(listen_auth, None, {():None=> None})
      .> on(DATA, {(conn: TCPConnection ref, data: Array[U8] iso) =>
           conn.log(consume data)
           conn.send("Pong") })
      .> listen("0.0.0.0", 7670)

      // client
      let cli = TCPConnection(conn_auth, None)
      .> on(CONN, {(self: TCPConnection ref) => self.send("Ping")})
      .> on(DATA, {(self: TCPConnection ref,  data: Array[U8] iso) =>
           self.log(consume data)
           self.send("Ping") })
      .> start("127.0.0.1", 7670, "")
    end

Recommend Projects