Simple RxJs Broadcast Service

Rohan Büchner

Rohan Büchner / April 06, 2017


I'm currently working on a system with decoupled components and services.

Still being new to Rxjs and Typescript (for Angular 2), I'm not 100% sure of all the utilities available in the RxJs arsenal, but today the need arose to have some form of generic pub/sub or broadcaster helper service.

The following seemed to do the trick for the time being. I'd like to improve or add the ability to only publish to specific subscribers without having to force a property in the payload that we need to use to discriminate who the consumers should be.

import {Injectable} from '@angular/core';
import {BehaviorSubject, Observable} from 'rxjs';

export class BroadcastService {

  broadcasts: Observable<any>;
  private _broadcasts: BehaviorSubject<any>;

  constructor() {
    this._broadcasts = <BehaviorSubject<any>>new BehaviorSubject({});
    this.broadcasts = this._broadcasts.asObservable();

  send(data): void {{}, data));

...and to use it:

import {Component} from '@angular/core';
import {BroadcastService} from "broadcast.service";

export class PublishComponent {

public broadcastService: BroadcastService;

constructor(public broadcastService: BroadcastService) {
  this.broadcastService = broadcastService;

public broadcast(): void {
  this.broadcastService.send({ data: [1, 2, 3], action: 'new' });

// somewhere else, eg: another file or component
broadcastService.broadcasts.subscribe(res => { console.log(res); });

Hope this helps anyone else who might need to do the same.