ebus v0.3.0

View Source ebus_ps_gc (ebus v0.3.0)

This is an Erlang clone of the original Phoenix.PubSub.GC module. Copyright (c) 2014 Chris McCord

Link to this section Summary

Functions

code_change(OldVsn, State, Extra)
down(GCServer, Pid)

Force table clean up because the given pid is down asynchronously.

handle_call(Request, From, State)
handle_cast(Request, State)
handle_info(Info, State)
init(_)
start_link(ServerName, LocalName)

Starts the server.

terminate(Reason, State)
unsubscribe(Pid, Topic, TopicsTable, PidsTable)
Removes subscriber's subscription for topic

Link to this section Functions

Link to this function

code_change(OldVsn, State, Extra)

View Source
Link to this function

down(GCServer, Pid)

View Source 
-spec down(atom(), pid()) -> ok.

Force table clean up because the given pid is down asynchronously.

  • GCServer: The registered server name or pid.
  • Pid: The subscriber pid.

Examples:

  > down(gc_server, self()).
  ok
Link to this function

handle_call(Request, From, State)

View Source
Link to this function

handle_cast(Request, State)

View Source
Link to this function

handle_info(Info, State)

View Source
Link to this function

init(_)

View Source
Link to this function

start_link(ServerName, LocalName)

View Source 
-spec start_link(atom(), atom()) -> gen_server:start_ret().

Starts the server.

  • ServerName: The name to register the server under.
  • LocalName: The name of the local table.
Link to this function

terminate(Reason, State)

View Source
Link to this function

unsubscribe(Pid, Topic, TopicsTable, PidsTable)

View Source 
-spec unsubscribe(pid(), binary(), atom(), atom()) -> ok.
Removes subscriber's subscription for topic