0.1.4 Version bump.

lib/redix/pubsub/fastlane/server.ex

@@ -110,11 +110,6 @@ defmodule Redix.PubSub.Fastlane.Server do
     {:noreply, %{ state | connected: false }}
   end
 
-  def handle_cast({:punsubscribe, [pattern], _}, state) do
-    IO.inspect pattern
-    {:noreply, %{ state | connected: false }}
-  end
-
   def handle_info({:redix_pubsub, redix_pid, operation, _}, %{redix_pid: redix_pid} = state) when operation in @subscribed_callbacks do
     {:noreply, state}
   end
@@ -150,19 +145,22 @@ defmodule Redix.PubSub.Fastlane.Server do
   defp _notify_all(subscribers, message, state) do
      payload = exclude_ns(message, state)
 
+     if is_nil(state.fastlane) do
+       _notify_all_embed(subscribers, payload)
+     else
+       state.fastlane.fastlane(subscribers, payload)
+     end
+  end
+
+  defp _notify_all_embed(subscribers, message) do
      subscribers
      |> Enum.each(fn
        {_from, %{pid: pid, options: options, parent: parent}} ->
-          _notify(pid, parent, payload, options, state.fastlane)
+          parent.fastlane(pid, message, options)
        _ -> :noop
      end)
   end
 
-  def _notify(pid, parent, payload, options, default_fastlane) do
-    module = parent || default_fastlane
-    module.fastlane(pid, payload, options)
-  end
-
   defp _find(channels, channel, from) do
     subscriptions =
       :ets.lookup(channels, channel)

mix.exs

@@ -2,7 +2,7 @@ defmodule RedixPubsubFastlane.Mixfile do
   use Mix.Project
 
   @project_url "https://github.com/merqlove/redix_pubsub_fastlane"
-  @version "0.1.3"
+  @version "0.1.4"
 
   def project do
     [app: :redix_pubsub_fastlane,

test/support/redix/pubsub/fastlane/namespace_test.exs

@@ -11,6 +11,15 @@ defmodule Redix.PubSub.Fastlane.NamespaceTest do
     GenServer.cast(pid, :stop)
   end
 
+  def fastlane(subscribers, message) do
+    subscribers
+    |> Enum.each(fn
+      {_from, %{pid: pid, options: options, parent: parent}} ->
+         __MODULE__.fastlane(pid, message, options)
+      _ -> :noop
+    end)
+  end
+
   def fastlane(pid, payload, options) do
     GenServer.cast({FastlaneTestNamespace, node()}, {:fastlane, pid, payload, options})
     :ok