As was pointed out by `artur grzesiak` in the comments, the `BehaviorSubject` interface was cleaned up, and the getter is now just `myBehaviorSubject.value`. 

I just wanted to add this as an answer because I almost didn&#39;t read the comments to the original question, and would have missed the correct answer.

Look at the source code to a behavior subject

https://github.com/ReactiveX/rxjs/blob/master/src/internal/BehaviorSubject.ts

It still has a getValue method, it has a value property that just calls getValue, it was there in RxJs5.

Here is a StackBlitz using RxJs5.

https://stackblitz.com/edit/typescript-gcbif4

All the comments talking about a breaking change in 6.5.0 are linking to comments about observables make with of not behavior subjects.

We&#39;re implementing a Job via [JobScheduler][1] for background loading of data. The job will fire about once a day. What tools are available for us to test this functionality (possibly ADB)?

Use cases are to be able to simulate the conditions required for a Job to be run or to just say specifically &quot;Run this job&quot; as part of our automated test suite.


  [1]: https://developer.android.com/reference/android/app/job/JobScheduler.html

What tools are available to test JobScheduler?

I use Android Studio to develop an application and I face this error which I have no idea how to solve.

&gt;com.android.dex.DexIndexOverflowException: method ID not in [0, 0xffff]

    :app:lintVitalRelease
    :app:prePackageMarkerForRelease
    :app:transformClassesWithDexForRelease FAILED
    Error:Execution failed for task &#39;:app:transformClassesWithDexForRelease&#39;.
    &gt; com.android.build.api.transform.TransformException: com.android.ide.common.process.ProcessException: java.util.concurrent.ExecutionException: com.android.dex.DexIndexOverflowException: method ID not in [0, 0xffff]: 65536
    Information:BUILD FAILED
    Information:Total time: 34.783 secs
    Information:1 error 



Android Studio DexIndexOverflowException: method ID not in

Previously in **rxjs4** there was a method in the BehaviorSubject called:
`getValue()` ([doc here][1]).

This method does not exist anymore in **rxjs5**.

So the only solution that I found to get the value of a BehaviorSubject was:

    let value;
    myBehaviorSubject.take(1).subscribe( (e) =&gt; value = e );

This code runs synchronously (I do not exactly understand why, but it does ...) and gets the value. It works, but it&#39;s not as clean as it could be if `getValue()` was present:

    let value = myBehaviorSubject.getValue();

Why `getValue()` was removed in **rxjs5** and what&#39;s the cleanest solution to this problem?

  [1]: https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/subjects/behaviorsubject.md#rxbehaviorsubjectprototypegetvalue


Simple way to get the current value of a BehaviorSubject with rxjs5

Previously in rxjs4 there was a method in the BehaviorSubject called:
<code>getValue()</code> (<a href="https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/subjects/behaviorsubject.md#rxbehaviorsubjectprototypegetvalue" target="_blank" rel="noopener noreferrer">doc here</a>).
This method does not exist anymore in rxjs5.
So the only solution that I found to get the value of a BehaviorSubject was:
<pre><code class="hljs language-ini">let value;
myBehaviorSubject.take(1).subscribe( (e) => value = e );
</code></pre>
This code runs synchronously (I do not exactly understand why, but it does ...) and gets the value. It works, but it's not as clean as it could be if <code>getValue()</code> was present:
<pre><code class="hljs language-ini">let value = myBehaviorSubject.getValue();
</code></pre>
Why <code>getValue()</code> was removed in rxjs5 and what's the cleanest solution to this problem?

Ok so maybe this is unclear. Get this form:

    &lt;form (ngSubmit)=&quot;submit()&quot; #crisisForm=&quot;ngForm&quot;&gt;
       &lt;input type=&quot;text&quot; name=&quot;name&quot; [(ngModel)]=&quot;crisis.name&quot;&gt;
       &lt;button type=&quot;submit&quot;&gt;Submit&lt;/button&gt;
       &lt;button type=&quot;button&quot; (click)=&quot;preview()&quot;&gt;Preview&lt;/button&gt;
       &lt;button type=&quot;reset&quot; (click)=&quot;reset()&quot;&gt;Reset&lt;/button&gt;
    &lt;/form&gt;

Why do all buttons trigger the `submit()` function ? And how to avoid that ?



Avoid Angular2 to systematically submit form on button click

I am getting this error in Console:

&gt;Uncaught TypeError: $.post is not a function

for this piece of code:

&lt;script type=&quot;text/javascript&quot; src=&quot;https://code.jquery.com/jquery-3.1.0.slim.min.js&quot;&gt;&lt;/script&gt;
	&lt;script type=&quot;text/javascript&quot;&gt;
		$(&#39;#cl_submit&#39;).click(function() { //#cl_submit is a button
			$(&#39;#cl_stage1msg&#39;).html(&#39;Processing...&#39;);
			$.post(&quot;process/cookie.php&quot;, $(&quot;#cl&quot;).serialize(), function(response) { //#cl is a form
				$(&#39;#cl_stage1msg&#39;).html(response);
			});
			return false;
		});
	&lt;/script&gt; &lt;!-- popup included --&gt;

I just couldn&#39;t find anything wrong in this. Why is this not working, any clues?

However, `$(&#39;#cl_stage1msg&#39;).html(&#39;Processing...&#39;);` is working fine.

Seems like only the post function is not getting recognised. 

I am using https://code.jquery.com/jquery-3.1.0.slim.min.js

Uncaught TypeError: $.post is not a function

I have an action making a `POST` request to the server in order to update a user&#39;s password, but I&#39;m unable to handle the error in the chained catch block.



    return axios({
      method: &#39;post&#39;,
      data: {
        password: currentPassword,
        new_password: newPassword
      },
      url: `path/to/endpoint`
    })
    .then(response =&gt; {
      dispatch(PasswordUpdateSuccess(response))
    })
    .catch(error =&gt; {
      console.log(&#39;ERROR&#39;, error)
      switch (error.type) {
        case &#39;password_invalid&#39;:
          dispatch(PasswordUpdateFailure(&#39;Incorrect current password&#39;))
          break
        case &#39;invalid_attributes&#39;:
          dispatch(PasswordUpdateFailure(&#39;Fields must not be blank&#39;))
          break
      }
    })

When I log the error this is what I see:
 
[![Error Logged][1]][1]




When I check the network tab I can see the response body, but for some reason I can&#39;t access the values!



[![Network Tab][2]][2]

Have I unknowingly made a mistake somewhere? Because I&#39;m handling other errors from different request fine, but can&#39;t seem to work this one out.

  [1]: http://i.stack.imgur.com/u6YS9.png
  [2]: http://i.stack.imgur.com/V8rQm.png

How to catch and handle error response 422 with Redux/Axios?

Is there an easy way to delete all registered users from firebase console?
For example, I created a hundred users from my development environment, and now I want to delete all of them.

Delete all users from firebase auth console

Let&#39;s say I have two arrays,

    var PlayerOne = [&#39;B&#39;, &#39;C&#39;, &#39;A&#39;, &#39;D&#39;];
    var PlayerTwo = [&#39;D&#39;, &#39;C&#39;];

What is the best way to check if arrayTwo is subset of arrayOne using javascript?

The reason: I was trying to sort out the basic logic for a game Tic tac toe, and got stuck in the middle. Here&#39;s my code anyway... Thanks heaps!

    var TicTacToe = {
    
    
      PlayerOne: [&#39;D&#39;,&#39;A&#39;, &#39;B&#39;, &#39;C&#39;],
      PlayerTwo: [],
    
      WinOptions: {
          WinOne: [&#39;A&#39;, &#39;B&#39;, &#39;C&#39;],
          WinTwo: [&#39;A&#39;, &#39;D&#39;, &#39;G&#39;],
          WinThree: [&#39;G&#39;, &#39;H&#39;, &#39;I&#39;],
          WinFour: [&#39;C&#39;, &#39;F&#39;, &#39;I&#39;],
          WinFive: [&#39;B&#39;, &#39;E&#39;, &#39;H&#39;],
          WinSix: [&#39;D&#39;, &#39;E&#39;, &#39;F&#39;],
          WinSeven: [&#39;A&#39;, &#39;E&#39;, &#39;I&#39;],
          WinEight: [&#39;C&#39;, &#39;E&#39;, &#39;G&#39;]
      },
    
      WinTicTacToe: function(){
    
        var WinOptions = this.WinOptions;
        var PlayerOne = this.PlayerOne;
        var PlayerTwo = this.PlayerTwo;
        var Win = [];
    
        for (var key in WinOptions) {
          var EachWinOptions = WinOptions[key];
    
            for (var i = 0; i &lt; EachWinOptions.length; i++) {
              if (PlayerOne.includes(EachWinOptions[i])) {
                (got stuck here...)
              }
    
            }
            // if (PlayerOne.length &lt; WinOptions[key]) {
            //   return false;
            // }
            // if (PlayerTwo.length &lt; WinOptions[key]) {
            //   return false;
            // }
            // 
            // if (PlayerOne === WinOptions[key].sort().join()) {
            //   console.log(&quot;PlayerOne has Won!&quot;);
            // }
            // if (PlayerTwo === WinOptions[key].sort().join()) {
            //   console.log(&quot;PlayerTwo has Won!&quot;);
            // } (tried this method but it turned out to be the wrong logic.)
        }
      },
    
    
    };
    TicTacToe.WinTicTacToe();



How to check if an array is a subset of another array in JavaScript?

I have used [Redux-Saga](https://github.com/yelouafi/redux-saga). Code written with it is easy to reason so far, except JS generator function is messing up my head from time to time. From my understanding, [Redux-Observable](https://github.com/redux-observable/redux-observable) can achieve the similar job that handles side effects but without using generator function. 

However, docs from Redux-Observable does not provide many opinions of why it is superior against Redux-Saga. I would want to know whether not using generator function is the only benefit of using Redux-Observable. And what could be the downsides, gotcha or compromises from using Redux-Observable instead of Redux-Saga? 



Why use Redux-Observable over Redux-Saga?

I&#39;ve been looking to understand those 3: 

* [Subject][1]
* [BehaviorSubject][2]
* [ReplaySubject][3]

I would like to use them and know when and why, what are the benefits of using them and although I&#39;ve read the documentation, watched tutorials and searched google I&#39;ve failed to make any sense of this.
 
So what are their purpose? A real-world case would be most appreciated it does not have to even code.

I would prefer a clean explanation not just &quot;a+b =&gt; c you are subscribed to ....&quot;

Thank you

[1]: https://rxjs.dev/api/index/class/Subject
[2]: https://rxjs.dev/api/index/class/BehaviorSubject
[3]: https://rxjs.dev/api/index/class/ReplaySubject

Subject vs BehaviorSubject vs ReplaySubject in Angular

In my app i have something like:

    this._personService.getName(id)
          .concat(this._documentService.getDocument())
          .subscribe((response) =&gt; {
                      console.log(response)
                      this.showForm()
           });
   
     //Output: 
     // [getnameResult]
     // [getDocumentResult]

     // I want:
     // [getnameResult][getDocumentResult]


Then i get two separated results, first of the `_personService` and then the `_documentService`. How can I wait for both results before call `this.showForm()` to finish an then manipulate the results of each one.


How to &#39;wait&#39; for two observables in RxJS

When to call the subscribeWith method rather than plain subscribe? And what is the use case?

    compositeDisposable.add(get()
        .observeOn(AndroidSchedulers.mainThread())
        .subscribeOn(Schedulers.io())
        .subscribe(this::handleResponse, this::handleError));

VS

       compositeDisposable.add(get()
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribeOn(Schedulers.io())
                  //  .subscribe(this::handleResponse, this::handleError);
                    .subscribeWith(new DisposableObserver&lt;News&gt;() {
                        @Override public void onNext(News value) {
                            handleResponse(value);
                        }
    
                        @Override public void onError(Throwable e) {
                            handleError(e);
                        }
    
                        @Override public void onComplete() {
                           // dispose here ? why? when the whole thing will get disposed later
                           //via  compositeDisposable.dispose();  in onDestroy();
                        }
                    }));


Thank you  


----------
**Added Later**
----------
According to the documentation, both return disposable SingleObserver instances:

    @CheckReturnValue
    @SchedulerSupport(SchedulerSupport.NONE)
    public final &lt;E extends SingleObserver&lt;? super T&gt;&gt; E subscribeWith(E observer) {
        subscribe(observer);
        return observer;
    }

    @SchedulerSupport(SchedulerSupport.NONE)
    public final Disposable subscribe(final Consumer&lt;? super T&gt; onSuccess, final Consumer&lt;? super Throwable&gt; onError) {
        ObjectHelper.requireNonNull(onSuccess, &quot;onSuccess is null&quot;);
        ObjectHelper.requireNonNull(onError, &quot;onError is null&quot;);
        ConsumerSingleObserver&lt;T&gt; s = new ConsumerSingleObserver&lt;T&gt;(onSuccess, onError);
        subscribe(s);
        return s;
    }

 Where ConsumerSingleObserver class implements SingleObserver and Disposable.



Subscribewith Vs subscribe in RxJava2(Android)?

We wrote a small Spring Boot REST application, which performs a REST request on another REST endpoint.

    @RequestMapping(&quot;/api/v1&quot;)
    @SpringBootApplication
    @RestController
    @Slf4j
    public class Application
    {
        @Autowired
        private WebClient webClient;
    
        @RequestMapping(value = &quot;/zyx&quot;, method = POST)
        @ResponseBody
        XyzApiResponse zyx(@RequestBody XyzApiRequest request, @RequestHeader HttpHeaders headers)
        {
            webClient.post()
                .uri(&quot;/api/v1/someapi&quot;)
                .accept(MediaType.APPLICATION_JSON)
                .contentType(MediaType.APPLICATION_JSON)
                .body(BodyInserters.fromObject(request.getData()))
                .exchange()
                .subscribeOn(Schedulers.elastic())
                .flatMap(response -&gt;
                        response.bodyToMono(XyzServiceResponse.class).map(r -&gt;
                        {
                            if (r != null)
                            {
                                r.setStatus(response.statusCode().value());
                            }
    
                            if (!response.statusCode().is2xxSuccessful())
                            {
                                throw new ProcessResponseException(
                                        &quot;Bad status response code &quot; + response.statusCode() + &quot;!&quot;);
                            }
    
                            return r;
                        }))
                .subscribe(body -&gt;
                {
                    // Do various things
                }, throwable -&gt;
                {
                    // This section handles request errors
                });
    
            return XyzApiResponse.OK;
        }
    }

We are new to Spring and are having trouble writing a Unit Test for this small code snippet.

Is there an elegant (reactive) way to mock the webClient itself or to start a mock server that the webClient can use as an endpoint?

How to mock Spring WebFlux WebClient?

I am trying to wrap my head around observables. I love the way observables solve development and readability issues. As I read, benefits are immense. 

Observables on HTTP and collections seem to be straight forward. How can I convert something like this to observable pattern.

This is from my service component, to provide authentication. I&#39;d prefer this to work like other HTTP services in Angular2 - with support for data, error and completion handlers.

```js
firebase.auth().createUserWithEmailAndPassword(email, password)
  .then(function(firebaseUser) {
    // do something to update your UI component
    // pass user object to UI component
  })
  .catch(function(error) {
    // Handle Errors here.
    var errorCode = error.code;
    var errorMessage = error.message;
    // ...
  });
```

Any help here would be much appreciated. The only alternative solution I had was to create `EventEmitter`s. But I guess that&#39;s a terrible way to do things in services section

Convert Promise to Observable

I&#39;m looking into Angular RxJs patterns and I don&#39;t understand the difference between a `BehaviorSubject` and an `Observable`.

From my understanding, a `BehaviorSubject` is a value that can change over time (can be subscribed to and subscribers can receive updated results). This seems to be the exact same purpose of an `Observable`.  

When would you use an `Observable` vs a `BehaviorSubject`? Are there benefits to using a `BehaviorSubject` over an `Observable` or vice versa?

BehaviorSubject vs Observable?

Hi I am using Angular 2 final with router 3.0. I want to filter the events that are emitted from `this.router.events`

What I want to do : 

&lt;!-- language: typescript --&gt;

    import &#39;rxjs/operator/filter&#39;;
    
    //...
    
    this.router.events
      .filter((event:Event) =&gt; event instanceof NavigationEnd)
      .subscribe(x =&gt; console.log(x))



`event` can be instanceOf `NavigationEnd`, `NavigationStart` or `RoutesRecognized` but I want only `NavigationEnd`. But I get an error that 

`Property &#39;filter&#39; does not exist on type Observable&lt;Event&gt;`

 during compile time.

When i import the whole `rxjs` library the error disappears. What should I import to make it work without loading the full rxjs library ?

Property &#39;filter&#39; does not exist on type &#39;Observable&lt;Event&gt;&#39;

I have an angular 2 service that fetch data from an API
this service has 3 subscribers (defined in Components) each doing something else with the data (different graphs)

I&#39;m noticing that I&#39;m doing three GET requests to the API while what i want to achieve is one request and that the subscribers will share the data
I&#39;ve looks into HOT and COLD observable and tried the .share() on the observable but I&#39;m still doing 3 individual calls

Update, adding code

&gt; Service

&lt;!-- language: lang-ts --&gt;

    import { Injectable } from &#39;@angular/core&#39;;
    import { Http, Response } from &#39;@angular/http&#39;;
    
    import {Observable} from &#39;rxjs/Rx&#39;;
    
    // Import RxJs required methods
    import &#39;rxjs/add/operator/map&#39;;
    import &#39;rxjs/add/operator/catch&#39;;
    
    import { StationCompliance } from &#39;./model/StationCompliance&#39;;
    
    
    @Injectable()
    export class StationComplianceService {
    
      private url = &#39;/api/read/stations&#39;;
    
      constructor(private http : Http) {
        console.log(&#39;Started Station compliance service&#39;);
       }
    
       getStationCompliance() : Observable&lt;StationCompliance []&gt; {
         return this.http.get(this.url)
          .map((res:Response) =&gt; res.json())
          .catch((error:any) =&gt; Observable.throw(error.json().error || &#39;Server Error&#39;));
       }
    }

&gt; Component 1

&lt;!-- language: lang-ts --&gt;

    import { Component, OnInit } from &#39;@angular/core&#39;;
    import { CHART_DIRECTIVES } from &#39;angular2-highcharts&#39;;
    
    import { StationComplianceService } from &#39;../station-compliance.service&#39;;
    
    
    @Component({
      selector: &#39;app-up-down-graph&#39;,
      templateUrl: &#39;./up-down-graph.component.html&#39;,
      styleUrls: [&#39;./up-down-graph.component.css&#39;]
    })
    export class UpDownGraphComponent implements OnInit {
    
      graphData;
    
      errorMessage: string;
    
      options;
    
      constructor(private stationService : StationComplianceService) { }
    
      ngOnInit() {
        this.getStationTypes();
      }
    
      getStationTypes(){
        this.stationService.getStationCompliance()
          .subscribe(
            graphData =&gt; {
              this.graphData = graphData;
              this.options = {
                chart : {type: &#39;pie&#39;,
                        plotShadow: true
                },
                plotOptions : {
                  showInLegend: true
                },
                title : {text: &#39;Up and Down devices&#39;},
                series: [{
                  data: this.processStationType(this.graphData)
                }]
              }
            },
            error =&gt; this.errorMessage = &lt;any&gt;error
          );
      }

Other two components are almost the same, they just show other graph

Angular 2 Observable with multiple subscribers

I&#39;m trying to return an observable when I get a certain value in a subscriber, but I fail miserably. 

This is the code:

    canActivate(route: ActivatedRouteSnapshot, state: RouterStateSnapshot):Observable&lt;boolean&gt; {
        // get route to be activated
        this.routeToActivate = route.routeConfig.path;

        // get user access levels        
        return this._firebase.isUserAdmin          &lt;-- returns Subscription, not Observable
            .map(user =&gt; user.access_level)
            .subscribe( access =&gt; {
               // I need to return an observable here
            });
    }

There are not many resources on observables in angular 2, so I don&#39;t know where to start. Can anyone help with this please?

**UPDATE -&gt; Working Version**

    canActivate(route: ActivatedRouteSnapshot, state: RouterStateSnapshot):Observable&lt;boolean&gt; {
                // get route to be activated
                this.routeToActivate = route.routeConfig.path;
        
                // get user access levels        
                return this._firebase.isUserAdmin
                    .map(user =&gt; {
                        let accessLevel = user.access_level;
                        
                        if (accessLevel === &#39;admin&#39; ) {
                            return true;
                        }
        
                    }).first();
            }

How to return observable from subscribe

&lt;!-- language-all: typescript --&gt;

I wonder, if there is any difference in performance between using `.take(1)` and `.unsubscribe` when `unsubscribe` is used right after the subscription:

    var observable = Rx.Observable.interval(100);

First:

    var subscription = observable.subscribe(function(value) {
       console.log(value);
    }).unsubscribe();

Second:

    var subscription = observable.take(1).subscribe(function(value) {
        console.log(value);
    });

Any ideas of it makes any different regard the performance?

Difference between .unsubscribe to .take(1)

According to [this artcle](http://paqmind.com/posts/rxjs-error-and-completed-events-demystified/), `onComplete` and `onError` function of the `subscribe` are mutually exclusive.  

Meaning either `onError` or `onComplete` events will fire up in my `subscribe`.  
I have a logic block which needs to be executed whether I receive an error, or I finish my steam of information successfully.  

I looked up for something like [`finally` in python](https://docs.python.org/3/tutorial/errors.html), but all I found is [`finally`](https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/finally.md) which needs to be attached to the observable I create.   

But I want to to do that logic only when I subscribe, and after the stream has ended, whether successfully or with an error.

Any ideas?

Observable Finally on Subscribe

I&#39;m wondering what are the differences between `Observable.combineLatest` and `Observable.forkJoin`?

As far as I can see, the only difference is `forkJoin` expects the Observables to be completed, while `combineLatest` returns the latest values.

Rxjs: Observable.combineLatest vs Observable.forkJoin

My backend frequently returns data as an *array inside an RxJS 5 Observable* (I&#39;m using Angular 2).

I often find myself wanting to **process the array items individually with RxJS operators** and I do so with the following code ([JSBin](http://jsbin.com/quqofe/edit?js,console)):

&lt;!-- language: lang-ts --&gt;

    const dataFromBackend = Rx.Observable.of([
      { name: &#39;item1&#39;, active: true },
      { name: &#39;item2&#39;, active: false },
      { name: &#39;item3&#39;, active: true }
    ]);
    
    dataFromBackend
      // At this point, the obs emits a SINGLE array of items
      .do(items =&gt; console.log(items))
      // I flatten the array so that the obs emits each item INDIVIDUALLY
      .mergeMap(val =&gt; val)
      // At this point, the obs emits each item individually
      .do(item =&gt; console.log(item))
      // I can keep transforming each item using RxJS operators.
      // Most likely, I will project the item into another obs with mergeMap()
      .map(item =&gt; item.name)
      // When I&#39;m done transforming the items, I gather them in a single array again
      .toArray()
      .subscribe();

The `mergeMap(val =&gt; val)` line doesn&#39;t feel very idiomatic.

Is there a better way to apply transformations to the members of an array that&#39;s emitted by an Observable?

NB. I want RxJS operators (vs array methods) to transform my items because I need the ability to project each item into a second observable. Typical use case: backend returns of list of item ids and I need to request all of these items from the backend.

Best way to &quot;flatten&quot; an array inside an RxJS Observable

*tl;dr: Basically I want to marry Angular&#39;s `ngOnDestroy` with the Rxjs `takeUntil()` operator. -- is that possible?*

I have an Angular component that opens several Rxjs subscriptions.
These need to be closed when the component is destroyed.

A simple solution for this would be:

    class myComponent {

      private subscriptionA;
      private subscriptionB;
      private subscriptionC;

      constructor(
        private serviceA: ServiceA,
        private serviceB: ServiceB,
        private serviceC: ServiceC) {}

      ngOnInit() {
        this.subscriptionA = this.serviceA.subscribe(...);
        this.subscriptionB = this.serviceB.subscribe(...);
        this.subscriptionC = this.serviceC.subscribe(...);
      }

      ngOnDestroy() {
        this.subscriptionA.unsubscribe();
        this.subscriptionB.unsubscribe();
        this.subscriptionC.unsubscribe();
      }

    }

This works, but it&#39;s a bit redundant. I especially don&#39;t like that
- The `unsubscribe()` is somewhere else, so you gotta remember that these are linked.
- The component state is polluted with the subscription.

I would much prefer using the `takeUntil()` operator or something similar, to make it look like this:

    class myComponent {

      constructor(
        private serviceA: ServiceA,
        private serviceB: ServiceB,
        private serviceC: ServiceC) {}

      ngOnInit() {
        const destroy = Observable.fromEvent(???).first();
        this.subscriptionA = this.serviceA.subscribe(...).takeUntil(destroy);
        this.subscriptionB = this.serviceB.subscribe(...).takeUntil(destroy);
        this.subscriptionC = this.serviceC.subscribe(...).takeUntil(destroy);
      }

    }

Is there a destroy event or something similar that would let me use `takeUntil()` or another way to simplify the component architecture like that?
I realize I could create an event myself in the constructor or something that gets triggered within `ngOnDestroy()` but that would in the end not make things that much simpler to read.

RxJS: takeUntil() Angular component&#39;s ngOnDestroy()

I&#39;m not clear on the difference between a `Subject` and a `BehaviorSubject`. Is it just that a `BehaviorSubject` has the `getValue()` function?

Content Type	Original Author	Original Content on Stackoverflow
Question	Clement	View Question on Stackoverflow
Solution 1 - Javascript	Tyson Phalp	View Answer on Stackoverflow
Solution 2 - Javascript	Adrian Brand	View Answer on Stackoverflow

Simple way to get the current value of a BehaviorSubject with rxjs5

Javascript Problem Overview

Javascript Solutions

Solution 1 - Javascript

Solution 2 - Javascript

Android Studio DexIndexOverflowException: method ID not in

What tools are available to test JobScheduler?

Attributions