How to get current value of RxJS Subject or Observable?

Baconbeastnz :

I have an Angular 2 service:

import {Storage} from './storage';
import {Injectable} from 'angular2/core';
import {Subject}    from 'rxjs/Subject';

@Injectable()
export class SessionStorage extends Storage {
  private _isLoggedInSource = new Subject<boolean>();
  isLoggedIn = this._isLoggedInSource.asObservable();
  constructor() {
    super('session');
  }
  setIsLoggedIn(value: boolean) {
    this.setItem('_isLoggedIn', value, () => {
      this._isLoggedInSource.next(value);
    });
  }
}

Everything works great. But I have another component which doesn't need to subscribe, it just needs to get the current value of isLoggedIn at a certain point in time. How can I do this?

Günter Zöchbauer :

A Subject or Observable doesn't have a current value. When a value is emitted, it is passed to subscribers and the Observable is done with it.

If you want to have a current value, use BehaviorSubject which is designed for exactly that purpose. BehaviorSubject keeps the last emitted value and emits it immediately to new subscribers.

It also has a method getValue() to get the current value.

Collected from the Internet

Please contact [email protected] to delete if infringement.

edited at
0

Comments

0 comments
Login to comment

Related

How to assign an initial value to Subject RxJS observable?

How do I emit the value of an observable to an rxjs Subject?

How to transform a Subject into an Observable in RxJs 5

RxJS Subject/Observable issue

RxJS - How can I map/switch a Subject Observable and add a mean calculation to every emitted value?

How do I get around this "Subject incorrectly extends Observable" error in TypeScript 2.4 and RxJS 5.x?

Get latest value of an Observable and a Behaviour Subject

RxJs get value from observable

RxJS Subject conditional next() update, based on current-new value

How can i get value from an Rxjs observable in my code?

How to get rxjs throttle with Subject to work properly?

rxjs - stop observable with a subject subscription

Pipe RxJS observable to existing subject

Get current value of RxJava Observable

RxJS - Return subject with value

How to get previous value Subject?

How to create Observable from Subject without exposing the Subject to consumers in RxJs v5

RxJS: How to subscribe to inner observable only when outer observable/subject is subscribed to?

How to get the value of observable?

Get current value of Subject.asObservable() inside Angular service

What is the difference between a Observable and a Subject in rxjs?

Angular rxjs private subject + public observable setup

Rxjs subject switch map to call another observable

How to skip first value of an observable with RxJS?

rxjs - Subject subscriber misses a value

How to test a subject and observable return value in Angular Jasmine Spec?

Rxjs: Is the observable born out of asObservable method of Subject the same as the source Subject?

How to get RxJS Observable events in zero time?

RxJS Observable on Axios how to get access to the Response

TOP Ranking

  1. 1

    Failed to listen on localhost:8000 (reason: Cannot assign requested address)

  2. 2

    Loopback Error: connect ECONNREFUSED 127.0.0.1:3306 (MAMP)

  3. 3

    How to import an asset in swift using Bundle.main.path() in a react-native native module

  4. 4

    pump.io port in URL

  5. 5

    Compiler error CS0246 (type or namespace not found) on using Ninject in ASP.NET vNext

  6. 6

    BigQuery - concatenate ignoring NULL

  7. 7

    ngClass error (Can't bind ngClass since it isn't a known property of div) in Angular 11.0.3

  8. 8

    ggplotly no applicable method for 'plotly_build' applied to an object of class "NULL" if statements

  9. 9

    Spring Boot JPA PostgreSQL Web App - Internal Authentication Error

  10. 10

    How to remove the extra space from right in a webview?

  11. 11

    java.lang.NullPointerException: Cannot read the array length because "<local3>" is null

  12. 12

    Jquery different data trapped from direct mousedown event and simulation via $(this).trigger('mousedown');

  13. 13

    flutter: dropdown item programmatically unselect problem

  14. 14

    How to use merge windows unallocated space into Ubuntu using GParted?

  15. 15

    Change dd-mm-yyyy date format of dataframe date column to yyyy-mm-dd

  16. 16

    Nuget add packages gives access denied errors

  17. 17

    Svchost high CPU from Microsoft.BingWeather app errors

  18. 18

    Can't pre-populate phone number and message body in SMS link on iPhones when SMS app is not running in the background

  19. 19

    12.04.3--- Dconf Editor won't show com>canonical>unity option

  20. 20

    Any way to remove trailing whitespace *FOR EDITED* lines in Eclipse [for Java]?

  21. 21

    maven-jaxb2-plugin cannot generate classes due to two declarations cause a collision in ObjectFactory class

HotTag

Archive