本文整理汇总了TypeScript中rxjs/Rx.Observer类的典型用法代码示例。如果您正苦于以下问题:TypeScript Observer类的具体用法?TypeScript Observer怎么用?TypeScript Observer使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了Observer类的10个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的TypeScript代码示例。
示例1: Notification
return this._http.post(this._apiBaseUrl, _n, { headers: headers }).map(response => response.json()).subscribe(data => {
this._dataStore.tracks.push(data[0]);
this._tracksObserver.next(this._dataStore.tracks);
this._newestTrackObserver.next(data[0]);
let trName = data[0].trackname;
this._notes.add(new Notification('info', trName + ' bætt við.'));
}, error => { this._notes.add(new Notification('error', 'Ekki tókst að tengjast gagnagrunni. Lagi ekki bætt við.')); });
开发者ID:kiddieverts,项目名称:hl,代码行数:8,代码来源:track.service.ts
示例2:
let obs: Observable<any> = Observable.create((observer: Observer<any>) => {
if (user.Email == "[email protected]" && user.Password == "123456") {
observer.next(true);
}
else {
observer.error("Invalid Credentials");
}
observer.complete();
//return () => { console.log("disposable called..."); }; //dispose observable
});
开发者ID:thakurarun,项目名称:listit,代码行数:10,代码来源:userService.ts
示例3:
(observer: Observer<any>) => {
if (!this.needsUpdate(url)) {
observer.next(this.cacheMap[url].data);
observer.complete();
}
this.call("get", url).subscribe(
res => {
this.storeData(url, res.json());
observer.next(this.cacheMap[url].data);
observer.complete();
}
);
}
开发者ID:audifaxdev,项目名称:ng2-restservice,代码行数:13,代码来源:RestService.ts
示例4: Notification
this._http.get(_url).map(response => response.json()).subscribe(data => {
// Set selectedProject
this._dataStore.selectedProject = data[0];
this._selectedProjectObserver.next(this._dataStore.selectedProject);
}, error => { this._notes.add(new Notification('error', 'Ekki tóst að sækja verkefni í gagnagrunninn.')); });
开发者ID:kiddieverts,项目名称:hl,代码行数:7,代码来源:project.service.ts
示例5: Notification
this._http.delete(_url).subscribe(response => {
// DELETE CREDITS FROM DATA STORE AND PUSH IT TO THE STREAM
this._dataStore.credits = this._dataStore.credits.filter(credit => credit.projecttrackid !== track.id);
this._creditsObserver.next(this._dataStore.credits);
}, error => { this._notes.add(new Notification('error', 'Ekki tókst að ná eyða flytjanda.')); });
开发者ID:kiddieverts,项目名称:hl,代码行数:7,代码来源:credit.service.ts
示例6:
position => {
const coordinate: Coordinate = {
latitude: position.coords.latitude,
longitude: position.coords.longitude
};
observer.next(coordinate);
observer.complete();
},
开发者ID:cristianrgreco,项目名称:nearby-pokemon,代码行数:8,代码来源:location.service.ts
示例7:
xhr.onreadystatechange = () => {
if (xhr.readyState === 4) {
if (xhr.status === 200) {
observer.next("test");
observer.complete();
} else {
observer.error(xhr.response);
}
}
};
开发者ID:icebluetech,项目名称:process-improvement-app,代码行数:10,代码来源:data.ts
示例8:
}).then((cmpRef: ComponentRef<TooltipComponent>) => {
// Store reference to TooltipComponent
this._toolTipCmp = cmpRef;
// Append it to DOM
this.viewContainer.element.nativeElement.appendChild(cmpRef.location.nativeElement);
// Resolve the component
observer.next(this._toolTipCmp);
observer.complete();
});
开发者ID:cviccaro,项目名称:jpa-admin,代码行数:11,代码来源:provider.ts
示例9: function
req.onload = function() {
if (req.status == 200) {
// If the status is 200, meaning there have been no problems,
// Yield the result to listeners and complete the sequence
observer.next(req.response);
observer.complete();
}
else {
// Otherwise, signal to listeners that there has been an error
observer.error(new Error(req.statusText));
}
};
开发者ID:MOHAMMADArsalan,项目名称:learn-typed-rxjs,代码行数:12,代码来源:main.ts
示例10:
Observable.forkJoin(fetchPages).subscribe(datas => {
let dataArray: any = datas;
dataArray.forEach((data: any) => {
comments = comments.concat(data.values);
},
(err: any) => {
observer.error(err);
});
let modelComments: Comment[] = comments.map((jsonComment: any) => {
console.log(jsonComment);
let content: CommentContent = {
html: jsonComment.content.html,
markup: jsonComment.content.markup,
raw: jsonComment.content.raw
};
let author: User = {
userName: jsonComment.user.username,
displayName: jsonComment.user.display_name,
uuid: jsonComment.user.uuid
};
let comment: Comment = {
content: content,
author: author
};
return comment;
});
// Return the result to the observers
observer.next(modelComments);
},
开发者ID:vnctaing,项目名称:stethoscope,代码行数:31,代码来源:bitbucket.service.ts
注:本文中的rxjs/Rx.Observer类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论