Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

How to create an observable in Angular 2

I am trying to evaluate Angular 2 and I am having problems with observables.

I am trying to create a simple service that initially returns a hard coded array but will eventually get the data from a webservice.

However, I can't get it to build OK.

Any ideas?

export class FleetListService {    private data: Observable<Array<IFleet>>;    constructor() { }    fleets: IFleet[] = JSON.parse( `[{ "id": 1, "name": "John", "description": "John has been in the Audio/Video industry since 1990. He has led DevAv as its CEO since 2003. When not working hard as the CEO, John loves to golf and bowl. He once bowled a perfect game of 300.", "childCount": 5, "isUsed": true },                                     { "id": 2, "name": "Olivia", "description": "Olivia loves to sell. She has been selling DevAV products since 2012. Olivia was homecoming queen in high school. She is expecting her first child in 6 months. Good Luck Olivia.", "childCount": 5 },                                     { "id": 3, "name": "Robert", "description": "Robert was recently voted the CMO of the year by CMO Magazine. He is a proud member of the DevAV Management Team. Robert is a championship BBQ chef, so when you get the chance ask him for his secret recipe.", "childCount": 4 },                                     { "id": 4, "name": "Greta", "description": "Greta has been DevAV's HR Manager since 2003. She joined DevAV from Sonee Corp.  Greta is currently training for the NYC marathon. Her best marathon time is 4 hours. Go Greta.", "childCount": 11 },                                     { "id": 5, "name": "Brett", "description": "Brett came to DevAv from Microsoft and has led our IT department since 2012.  When he is not working hard for DevAV, he coaches Little League (he was a high school pitcher).", "childCount": 13 },                                     { "id": 6, "name": "Sandra", "description": "Sandra is a CPA and has been our controller since 2008. She loves to interact with staff so if you've not met her, be certain to say hi.  Sandra has 2 daughters both of whom are accomplished gymnasts.", "childCount": 44 },                                     { "id": 7, "name": "Kevin", "description": "Kevin is our hard-working shipping manager and has been helping that department work like clockwork for 18 months.  When not in the office, he is usually on the basketball court playing pick-up games.", "childCount": 5 },                                     { "id": 8, "name": "Cynthia", "description": "Cindy joined us in 2008 and has been in the HR department for 2 years.   She was recently awarded employee of the month. Way to go Cindy!", "childCount": 4 },                                     { "id": 9, "name": "Kent", "description": "As our ombudsman, Kent is on the front-lines solving customer problems and helping our partners address issues out in the field.    He is a classically trained musician and is a member of the Chamber Orchestra.", "childCount": 26 },                                     { "id": 10, "name": "Taylor", "description": "If you are like the rest of us at DevAV, then you've probably reached out for help from Taylor. He does a great job as a member of our IT department.", "childCount": 5 },                                     { "id": 11, "name": "Sam", "description": "Sammy is proud to be a member of the DevAV team. He joined the team in 2012 and has been in the sales department from the beginning.  He has just picked up golf so you can find him on the links every weekend.", "childCount": 11 },                                     { "id": 12, "name": "Kelly", "description": "Kelly loves people and that's why she joined DevAV's support department. One of the funniest people in the company, she does stand-up on the weekends at the Laugh Factory.", "childCount": 5 },                                     { "id": 13, "name": "Natalie", "description": "Natalie travels the US and teaches our partners how to explain the benefits of our products to customers.  She is a proud wife and mom and volunteers her time at the elementary school.", "childCount": 29 },                                     { "id": 14, "name": "Walter", "description": "Walter has been developing apps and websites for DevAV since 2011. His passion is software and if you ever walk by his desk, you'll know why.  Wally once worked 72 hours straight - writing code and fixing bugs.", "childCount": 13 }]`);    getFleets(): Observable<IFleet[]> {     return new Observable((data : IFleet[]) => {       return this.fleets;     }   } } 
like image 431
Al_B Avatar asked Jan 23 '17 12:01

Al_B


People also ask

How do you make observables?

We start by creating the subject, then create two Observers that will log each value they receive from the Subject (Observable). We tell the Subject to push the value 1 . We then create ObserverC which also logs each value it receives from the Subject. Finally, we tell the Subject to push the value 2 .

How do I create an observable in Angular 8?

We can use the observable constructor to create an observable stream of any type. The observable's subscribe() executes with the constructor argument. The Observer object received by a subscriber function then publishes values using the observer's next() method. Add or modify the RxJS import to add Observer function.

How many ways we can create observable in Angular?

In Angular we can subscribe to an observable in two ways: Manner 1: We subscribe to an observable in our template using the async pipe. The benefit of this is that Angular deals with your subscription during the lifecycle of a component.


2 Answers

You can use Observable.of method.

getFleets(): Observable<IFleet[]> {      return Observable.of(this.fleet) } 

Don't forget to import of using the following line

   import "rxjs/add/observable/of";  // For RxJs  5.0+ 

For RxJS 6.x

getFleets(): Observable<IFleet[]> {          return of(this.fleet)     } 

Import statement for "of"

import { of } from "rxjs"; 
like image 182
Basavaraj Bhusani Avatar answered Sep 28 '22 08:09

Basavaraj Bhusani


This is coming a bit late, just for clarification anyways. This is how you can create a simple observable in case you want to mimic your own like promise. You do

let observable=Observable.create(observer => {       setTimeout(() => {         observer.next("data to send can be object or anything");         console.log("am done");         observer.complete(); // to show we are done with our processing        // observer.error(new Error("error message"));       }, 2000);      }) 

to subscribe to it is very easy

observable.subscribe((data) => { console.log(data); // should be 'data to send can be object or anything' }); 

you can also convert it to promise using toPromise() or fromPromise(observable) operator and so on.

like image 43
Theophilus Omoregbee Avatar answered Sep 28 '22 10:09

Theophilus Omoregbee