Rxjs subject in ionic in details

In this post, we are going to introduce RxJS subject in ionic and how we can use them in Ionic 5 of the Angular project. Observables are unicasting. It means all subscribers get a new instance of observable. A regular observable does not have the next() method as regular observable ‘s are not observers. We can use the subject to emit data.

Second Subjects in RxJS are multicasting. A Subject is like an Observable, but can multicast to many Observers. Subjects are like EventEmitters: they maintain a registry of many listeners. Internally to the Subject, subscribe does not invoke a new execution that delivers values. It simply registers the given Observer in a list of Observers, similarly to how addListener usually works in other libraries and languages.

The RXJS offers different types of Subjects, namely: BehaviorSubject, ReplaySubject and AsyncSubject.

BehaviorSubject:  A subject that stores the latest value, and immediately sends it to new subscribers. It means even after subscription, you can access it’s current value until unless value erased with new entry.

ReplaySubject: Replay subjects stores user specific number of values for user specific time. Upto the time, you could access those values.

AsyncSubject:  A subject that waits until it is complete, then sends the final value to any subscribers (even latecomers).

The subject is both an observable and observer.
Observer — it has the next, error, and complete methods.
Observable — it has all the observable operators, and you can subscribe to him.

In this example we will used simple subject, whenever we add or delete a course in courses array object, it will update its latest state of courses variable to subject’s subscribers will, in turn, receive that pushed data.

Rxjs subject in ionic

We have a courseService provider, where we have a variable called courses containing the value of all courses. Every Subject is an Observer. It is an object with the methods next(v), error(e), and complete(). To feed a new value to the Subject, just call next(theValue), and it will be multicasted to the Observers registered to listen to the Subject.

In the example below, we have can add or delete course objects from the courses variable, when we are adding or deleting a course, will call the next method on Subject and we feed the current state of course list object to the Subject:

Step 1: Create project >> ionic start rxjsSubjectApp blank
Step 2: Create CourseService provider in our project as
>> ionic generate service course
Add following code in course.service.ts file

import { Injectable } from '@angular/core';
import { Subject } from 'rxjs';

  providedIn: 'root'
export class CourseService {
  courses = [
    { name: 'Nodejs', type: 'Free' },
    { name: 'Angular', type: 'Premium' },
    { name: 'Java', type: 'Premium' }
  currentCourse = new Subject<any[]>();

  constructor() { }

  addCourse(course) {
    /* do something with the value */

  deleteCourse(course) {
    this.courses = this.courses.filter((item) => {
      return item.name !== course.name;
    /* do something with the value */


In our course.service.ts file, we need to import the Subject from Rxjs Library. In our course.service we add currentCourse variable of type Subject containing a list of courses in the latest state.  So whenever we are adding or deleting are emitting event by calling next on currentCourse by feed the latest state of courses as a parameter in the next method. In home.page we are subscribing to currentCourse.

Step 3: In the home page template we have a form for adding and deleting a new course. We also needed to import Subscription from Rxjs library. Add following code in home.page.html

      Rxjs Subject

  <ion-card class="ion-padding ion-text-center">
    <ion-text color="primary">Add Course Name</ion-text>
      <ion-input [(ngModel)]="newCourse.name" placeholder="course name"></ion-input>
      <ion-label position="floating">Type</ion-label>
      <ion-select [(ngModel)]="newCourse.type">
        <ion-select-option value="Free">Free</ion-select-option>
        <ion-select-option value="Premium">Premium</ion-select-option>
    <ion-button class="ion-float-right" shape="round" (click)="addCourse()">Add</ion-button>

    <ion-item-sliding *ngFor="let course of courses">
      <ion-item-options side="start">
        <ion-item-option color="danger" (click)="deleteCourse(course)">Delete</ion-item-option>
        <ion-label>{{ course.name }} : {{ course.type }}</ion-label>


Add following code in home.page.ts file.

import { Component, OnInit, OnDestroy } from '@angular/core';
import { CourseService } from '../course.service';
import { Subscription } from 'rxjs';

  selector: 'app-home',
  templateUrl: 'home.page.html',
  styleUrls: ['home.page.scss'],
export class HomePage implements OnInit, OnDestroy {
  courses: any[];
  newCourse = { name: '', type: ''};
  private courseListSub: Subscription;

  constructor(private courseService: CourseService) { }

  ngOnInit() {
    this.courses = this.courseService.courses;
    this.courseListSub = this.courseService.currentCourse.subscribe((courses) => {
      this.courses = courses;

  addCourse() {

  deleteCourse(course) {

  ngOnDestroy() {


We will import the CourseService provider on our page and we need to unsubscribe the subscription so we have called unsubscribe on courseListSub variable.

Check more information on the Rxjs subject in ionic angular on official Rxjs documentation.

Leave a Comment

Your email address will not be published. Required fields are marked *

Scroll to Top