Skip to content

Instantly share code, notes, and snippets.

@rbishop

rbishop/README.md

Last active April 11, 2025 17:56
Show Gist options
  • Save rbishop/e7b1886d5e75b2f74d8b to your computer and use it in GitHub Desktop.
Save rbishop/e7b1886d5e75b2f74d8b to your computer and use it in GitHub Desktop.
Download ZIP
A super simple Elixir server for sending Server Sent Events to the browser.
Raw
README.md

Generate a new Elixir project using mix and add cowboy and plug as dependencies in mix.exs:

  defp deps do
    [
      {:cowboy, "~> 1.0.0"},
      {:plug, "~> 0.8.1"}
    ]
  end

Then add the sse.ex file below to lib/ and run the code with mix run --no-halt lib/sse.ex. Point your browser to http://localhost:4000 and you're done.

If you don't feel like writing your own EventSource JavaScript, you can use the example in index.html below that comes from Cowboy. Just create a priv/static directory inside of your project.

Raw
index.html
<!DOCTYPE html>
<html>
<head>
<script type="text/javascript">
function ready() {
if (!!window.EventSource) {
setupEventSource();
} else {
document.getElementById('status').innerHTML =
"Sorry but your browser doesn't support the EventSource API";
}
}
function setupEventSource() {
var source = new EventSource('/sse');
source.addEventListener('message', function(event) {
addStatus("server sent the following: '" + event.data + "'");
}, false);
source.addEventListener('open', function(event) {
addStatus('eventsource connected.')
}, false);
source.addEventListener('error', function(event) {
if (event.eventPhase == EventSource.CLOSED) {
addStatus('eventsource was closed.')
}
}, false);
}
function addStatus(text) {
var date = new Date();
document.getElementById('status').innerHTML
= document.getElementById('status').innerHTML
+ date + ": " + text + "<br/>";
}
</script>
</head>
<body onload="ready();">
Hi!
<div id="status"></div>
</body>
</html>
Raw
sse.ex
defmodule Sse do
import Plug.Conn
use Plug.Router
plug :match
plug :dispatch
get "/" do
conn
|> put_resp_header("content-type", "text/html")
|> send_file(200, "priv/static/index.html")
end
get "/sse" do
conn = put_resp_header(conn, "content-type", "text/event-stream")
conn = send_chunked(conn, 200)
send_message(conn, "Look, Ma'! I'm streaming!")
:timer.sleep(1000)
send_message(conn, "It only took two lines of code!")
:timer.sleep(1000)
send_message(conn, "All you have to do is set a header and chunk the response!")
:timer.sleep(1000)
send_message(conn, "Bye now!")
conn
end
defp send_message(conn, message) do
chunk(conn, "event: \"message\"\n\ndata: {\"message\": \"#{message}\"}\n\n")
end
end
# Run with mix run --no-halt lib/sse.ex
Plug.Adapters.Cowboy.http Sse, [], port: 4000
@HamptonMakes
Copy link

HamptonMakes commented Nov 8, 2020

Oh, holding open WS connections is very expensive. Also, the SSE limit of 6 only applies to HTTP/1 connections and assuming you aren't using a CDN to route your SSE.

@MosesMuiru
Copy link

MosesMuiru commented Jan 29, 2025

happy new year: 2025
I found my self here

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment