diff options
author | kballou <kballou@devnulllabs.io> | 2016-10-30 23:05:23 -0600 |
---|---|---|
committer | kballou <kballou@devnulllabs.io> | 2016-10-30 23:07:59 -0600 |
commit | 62b532d0f0236bf91451c7e4bacacc34799caaa6 (patch) | |
tree | 96b3f40a46be4ed4bda5eef2aace61ccf52ec0f1 /lib/octochat/servers/echo.ex | |
parent | 35325ce024b36672aca33f08bf61adf3570445bf (diff) | |
download | octochat-62b532d0f0236bf91451c7e4bacacc34799caaa6.tar.gz octochat-62b532d0f0236bf91451c7e4bacacc34799caaa6.tar.xz |
Add echo server and hook into acceptorv0.2.0
Diffstat (limited to 'lib/octochat/servers/echo.ex')
-rw-r--r-- | lib/octochat/servers/echo.ex | 23 |
1 files changed, 23 insertions, 0 deletions
diff --git a/lib/octochat/servers/echo.ex b/lib/octochat/servers/echo.ex new file mode 100644 index 0000000..fe25079 --- /dev/null +++ b/lib/octochat/servers/echo.ex @@ -0,0 +1,23 @@ +defmodule Octochat.Echo do + @moduledoc """ + Octochat Echo server + """ + + def serve(socket) do + socket + |> read_line!() + |> write_line!(socket) + + serve(socket) + end + + defp read_line!(socket) do + {:ok, line} = :gen_tcp.recv(socket, 0) + line + end + + defp write_line!(line, socket) do + :gen_tcp.send(socket, line) + end + +end |