]> Entropealabs - wampex_router.git/commitdiff
handle binary or list for subscribed message handling
authorChristopher <chris@entropealabs.com>
Wed, 18 Mar 2020 20:54:00 +0000 (15:54 -0500)
committerChristopher <chris@entropealabs.com>
Wed, 18 Mar 2020 20:54:00 +0000 (15:54 -0500)
lib/roles/subscriber.ex

index de25f2ed7f68ceea83677abe1e220900511f45c4..62536ec6b06c4399dc45e8e11d0f11b76f831ac6 100644 (file)
@@ -55,6 +55,11 @@ defmodule Wampex.Roles.Subscriber do
 
   @impl true
   def handle(<<@unsubscribed, request_id>>) do
+    handle([@unsubscribed, request_id])
+  end
+
+  @impl true
+  def handle([@unsubscribed, request_id]) do
     {[{:next_event, :internal, :established}], request_id, :ok}
   end