tmbb

tmbb

Guaranteeing order with phoenix channels

For a project, I’m using channels to handle realtime notifications and synchronization between clients. I send the initial state embedded in the DOM and use channels to listen to updates from the server. However, there is a time between the HTML leaving the server and the channel being setup on the client during which I’m “blind” and won’t receive events.

Is there any way to guarantee that I won’t have such a window during which events are not acknowledged?

I was thinking of the following: instead of embedding the state in the DOM, I could ask for the initial state through the channel. Does this guarantee that I will only receive the events in the browser after receiving the initial state? Where can I read abou the “ordering” garanteed of phoenix channel communication?

Marked As Solved

hubertlepicki

hubertlepicki

So the order of messages received by client of channel will always be the order of events that were sent to given channel. The client will always also receive all messages, even if they are outdated.

It looks like a good thing in your case. You are right, that you will have a gap window between the time when user loads initial HTML page, and when the channel connection is established, and you can miss some updates, yes.

If this is mission critical not to loose any events that happen in the meantime, you can either do what you suggest - load whole state, including initial state via channel. Alternatively, you can start a process on each GET request, that would be tied to that get request and future channel by some UUID for example. You generate UUID, send with your HTML, start a process with the same UUID, and start a channel with the same UUID. Rather than pushing the messages to channel directly, you use your newly created process as a buffer. But it’s way more complicated than simply loading all the state via phoenix channel.

Also Liked

OvermindDL1

OvermindDL1

The order of events is incidental in that it is the BEAM that assures that messages are passed to the network stack in order and TCP is an in-order protocol. Ordering between ‘different’ process are not ordered though, and that is reflected in channels. Different Channel messages can arrive in any order.

Where Next?

Popular in Questions Top

vertexbuffer
Hello, can anybody help here..? I have a list of players and I what to delete an element, but every for loop the list is reverting to ori...
New
siddhant3030
Hi, I have to write a raw query for one of my project. But till now I have used ecto queries and don’t have much experience writing raw ...
New
qwerescape
Is there a way to get the call stack or stack trace at any point in the code? Not from exceptions, but an expression that returns how the...
New
Patoshizzle
After calling mix ecto.create I get this error: 17:00:32.162 [error] GenServer #PID<0.412.0> terminating ** (Postgrex.Error) FATAL...
New
minhajuddin
I have seen a lot of code which picks the first element from a list using Enum.at(0) instead of List.first. Is there a reason why people ...
New
stefanchrobot
What’s the safe way to decode a JSON string into a struct? I want to avoid calling String.to_atom. Jason.decode can give me a map with st...
New
itssasanka
Hi all, Trying to get some more clarity over utc_datetime and naive_datetime for Ecto: The documentation above suggests that while ...
New
rms.mrcs
Hi, I need to transform a list of numbers into a map where the keys are the indexes and the values are the original values of the list. ...
New
komlanvi
Hi everyone, I was playing with phoenix liveView but I run into an issue. I have a form and want to validate each input text when the te...
New
shijith.k
I am trying to start a new phoenix project with elixir 1.9, but mix phx.new does not work. It says that ** (Mix) The task "phx.new" could...
New

Other popular topics Top

marius95
Hello everyone, I try to use an Javascript Event Handler in my root.html.leex file. Therefore I created a function in the app.js file: ...
New
Harrisonl
We have an ECS cluster with 4 services, where each task joins a single cluster, via discovery ECS discovery service. Currently when I de...
New
chrismccord
As promised, the first release candidate of Phoenix 1.3.0 is out! This release focuses on code generators with improved project structure...
New
Patoshizzle
After calling mix ecto.create I get this error: 17:00:32.162 [error] GenServer #PID<0.412.0> terminating ** (Postgrex.Error) FATAL...
New
johnnyicon
Hi all, I’ve just started learning Elixir and Phoenix Framework, so please pardon my n00bness at this stage. I’m trying to use Postgres...
New
chrismccord
This release brings a number of exciting features, including integration with the new Phoenix LiveDashboard and Phoenix LiveView. There h...
New
JorisKok
I have a server on AWS, and was running a load test using artillery. When looking at the Phoenix dashboard I see the Ports going to 100% ...
New
hariharasudhan94
lets say i have a sample like a = 20; b = 10; if (a > b) do {:ok, "a"} end if (a < b) do {:ok, b} end if (a == b) do {:ok, "equa...
New
shijith.k
I am trying to start a new phoenix project with elixir 1.9, but mix phx.new does not work. It says that ** (Mix) The task "phx.new" could...
New
joaquinalcerro
Hi there, I am working with Ecto-Postgresql and I need to call all of the records from a specific table but the table has 40,000 records...
New

Latest on Elixir Forum

We're in Beta

About us Mission Statement