neuroevolution_events_local (faber_neuroevolution v1.2.4)

Local event backend using Erlang's pg (process groups).

This is the default backend for single-node or development use. For distributed operation, use neuroevolution_events_macula.

Subscribers receive messages in the format: {neuro_event, Topic, Event}

Subscribe to events: neuroevolution_events:subscribe(Topic)

In handle_info: handle_info({neuro_event, Topic, Event}, State) -> io:format("Received ~p on ~p~n", [Event, Topic]), {noreply, State}.

Summary

Publish an event to all subscribers of a topic.

start()

Start the local event system.

Subscribe a process to a topic.

Unsubscribe a process from a topic.

-spec publish(Topic, Event) -> ok when Topic :: binary(), Event :: term().

Publish an event to all subscribers of a topic.

-spec start() -> ok.

Start the local event system.

This must be called once at application startup to initialize the pg scope. It's safe to call multiple times.

-spec unsubscribe(Topic, Pid) -> ok when Topic :: binary(), Pid :: pid().

Unsubscribe a process from a topic.