Dan Dan - 1 year ago 97
AngularJS Question

How to create a pub/sub pattern using AngularJS

I am writing a SPA using angular (1.4.7) and to keep the complexity down I'd been attempting to abstract the persistence logic to a factory/repository.

This is nothing special and seems to work fine.

One feature I'd like to implement is the ability for a "parent" scope to update when the user updates some personal information.

See the example https://jsfiddle.net/h1r9zjt4/

I've taken a look at various ways of implementing this and a few ways I've seen are:

  • Use $rootScope to share common objects
    I've been attempting to steer away from using scopes and to only use the
    syntax. This seems to be the advised solution to keep a strict/robust separation between controller and view.

  • Use $scope.$parent to access the required property
    For similar reasons, this couples my view implementation to my controller implementation.

  • Use $on/$emit to communicate between controllers

    As well as sounding like an eventual maintenance nightmare, this inherently means that controllers know about other controllers. Not ideal.

My ideal scenario would be to have a pub/sub scenario.

My user updating their details will be handled by the repository which in-turn sends a command or fulfils a promise to all subscribers of that repository.

Is this a standard angular pattern? If not, what would a suitable alternative be?

Answer Source

Although it's mostly associated with the React world, what you are looking for is Flux. It's even been ported to Angular in the form of flux-angular.

Flux enforces a pattern for how you think about data flowing through your application.

The shared models that allow you to publish and subscribe to changes with are called stores. However, you don't speak to them in the conventional pubsub way.


A store is responsible for looking after some data and handling any actions that you trigger. For instance a store for a counter might look something like this:

app.store('CounterStore', function() {
  return {
    count: 0,
    increment: function() {
      this.count = this.count + 1;
    decrement: function() {
      this.count = this.count - 1;
    exports: {
      getCount: function() {
        return this.count;

Then inject your store into a controller or directive to listen for changes.

Think of this as the subscription part of a pub/sub architecture.

app.directive('Counter', function() {
  return {
    template: '<div ng-bind='count'></div>',
    controller: function($scope, CounterStore) {
      $scope.listenTo(CounterStore, function() {
        $scope.count = CounterStore.getCount();


The other piece in the Flux puzzle is dispatching actions. This is the publishing part of a pub/sub architecture, on steroids.

Rather than emitting events like you could do with the root scope's event emitter, you dispatch serializable actions and Flux does the rest for you.

Let's define a final directive to control the counter in the previous directive, using Flux.

app.directive('CounterControls', function() {
  return {
    template: '<button ng-click="inc()">+</button>' + 
              '<button ng-click="dec()">-</button>',
    controller: function($scope, flux) {
      $scope.inc = function() {

      $scope.dec = function() {

This code doesn't even know about the store! It just knows that these are the actions that should be dispatched when these buttons are clicked.

Once these actions have been dispatched, Flux uses the name of the action to call the appropriate functions within the stores. These stores update their data and if necessary, they emit a change, notifying the subscribers so that they can update their data too.

It might seem like a lot of code for sharing a counter between two directives, but it's a very powerful idea and in the long term will keep the architecture of your application clean and concise.


Flux is a pretty cool architecture. Here's a run down of why it might suit you better than the other solutions you mentioned.

Separation of Concerns

Flux allows you to move all state management code out into loosely coupled modules called stores. This way none of your controllers will ever have to know about any other controllers.

Serializable Actions

If you make sure that you only dispatch actions that can be serialized, then you can keep a track of every action that's fired in your application, meaning it's possible to recreate any state, by simplying re-playing the same actions again.

To get some idea of just how cool this can be, check out this video about time travel with a Flux implementation called Redux.

One Way Data

It's easier to reason about your program when data only flows in one direction. When you use Flux, there's no reason to ever communicate with any components other than your children.

 / \  |
/   v |
B   D |
|  /  |
| /   |

In a more traditional pub/sub architecture, if directive C wanted to communicate with directive A and D it would have to maintain a complex entangled hierarchy, which gets more and more difficult to manage each time you let one directive or controller know about another.

It's not clear which way the data is flowing because directives can communicate with eachother, regardless of where they are.

  A <------------+
 / \             |
v   v            |
B   D  <----- [store]
|                ^
v                |
C --> [action] --+

With Flux, your directives only communicate with their children and with stores — data flows in one direction round your application, making it much easier to work out how a value got somewhere, or why a function was called.

Recommended from our users: Dynamic Network Monitoring from WhatsUp Gold from IPSwitch. Free Download