- c - 在位数组中找到第一个零
- linux - Unix 显示有关匹配两种模式之一的文件的信息
- 正则表达式替换多个文件
- linux - 隐藏来自 xtrace 的命令
我正致力于通过 Angular2/TypeScript 实现搜索功能。
但是,我在绑定(bind)返回到 View 的搜索项时遇到了一些问题。
我的组件是这样的:
import { Component } from '@angular/core';
import { SearchService } from '../services/search.service';
import { Observable } from 'rxjs/Observable';
import { Subject } from 'rxjs/Subject';
import "rxjs/add/operator/debounceTime";
import "rxjs/add/operator/distinctUntilChanged";
import 'rxjs/add/operator/switchMap';
@Component({
selector: 'search',
templateUrl: './app/views/search.component.html',
providers: [SearchService]
})
export class SearchComponent {
items: Observable<string[]>;
errorMsg: string;
private searchTermStream = new Subject<string>();
searchConfluence(term : string) {
// Send the search term into the Observable stream
this.searchTermStream.next(term);
}
ngOnInit(): void {
this.items = this.searchTermStream
.debounceTime(300)
.distinctUntilChanged()
.switchMap(term => this.searchService.titleSearch(term));
}
constructor(private searchService: SearchService) {}
}
我的观点如下:
<h1>Search</h1>
<input #term (keyup)="searchConfluence(term.value)" />
<ul style="list-style: none">
<li *ngFor="let item of items | async">
{{item.title}}
</li>
</ul>
我的搜索服务:
import { Injectable } from '@angular/core';
import { Http, Response, Headers, RequestOptions } from '@angular/http';
import { Observable } from 'rxjs/Observable';
import 'rxjs/add/operator/map';
import 'rxjs/add/operator/catch';
import 'rxjs/add/observable/throw';
@Injectable()
export class SearchService {
private searchUrl = URL_HERE;
constructor(private http: Http) {}
titleSearch(params: string): Observable<string[]> {
let options = new RequestOptions({ headers: this.header});
let requestString = `term=${params}`;
return this.http.get(`${this.searchUrl}?${requestString}`, options)
.map(this.getData)
.catch(this.handleError);
}
private getData(resp: Response) {
let body = resp.json();
console.log(body.results);
return body.results || [];
}
private handleError(error: Response | any) {
let errMsg: string;
if (error instanceof Response) {
const body = error.json() || '';
const err = body.error || JSON.stringify(body);
errMsg = `${error.status} - ${error.statusText || ''} ${err}`;
} else {
errMsg = error.message ? error.message : error.toString();
}
return Observable.throw(errMsg);
}
}
服务器返回的响应如下:
[Object, Object ... ]
其中每个 Object
都是一个 JSON 对象。这就是我期待的回应。
我已经检查了网络跟踪并且 HTTP 请求被触发到正确的位置并且我也得到了结果(同样,所有这些都是通过网络跟踪查看的)。我无法在我的 View 中查看任何结果(该列表根本没有出现)。
编辑:最后一次编辑,但我可能遗漏了一个关键细节;我的 Angular2 应用程序不在典型的浏览器中,但实际上包含在 ElectronJS 应用程序中。我不确定这是否有任何不同。
最佳答案
经过一天的折腾,我得到了这个问题的答案。
看起来 Electron 的 API 更新速度不如 Web 浏览器那么快,所以我遵循了 here 中的解决方案。 .
基本上我在我的 search.component.ts
类中这样做:
ngOnInit(): void {
this.searchTermStream
.debounceTime(300)
.distinctUntilChanged()
.switchMap(term => this.searchService.titleSearch(term))
.subscribe((result) => {
this.items = result;
this.cdRef.detectChanges();
});
}
瞧,一切都在正确更新,我有一个很好的搜索结果列表:)。
关于Angular2 Observable 绑定(bind)不正确,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/40816006/
一段时间后,我阅读了有关 RxJava concat 的内容,并决定测试一下我的理解力。但是我遇到了一些我不太理解的行为。 问题是,当我连接两个可观察对象时,根据我将它们传递给 Observable.
我正在使用来自数据库服务的数据实现自动完成: @Injectable() export class SchoolService { constructor(private db: AngularF
我正在尝试使用 RxJS 创建一个可观察的对象,它可以执行如图所示的操作。 获取一个值并等待一段固定的时间才能获得 下一个。 下一个将是该周期内发出的最后一个值 等等,跳过其余部分。 如果等待时间间隔
我有一个可观察对象和另一个提供的可观察对象改变 key 。我想构建一个在之间切换的可观察对象基于该键的对象中的可观察值。 示例: // Choose randomly between "up" or
我使用 protobuffers 在我的前端和我的 Dart 服务器之间进行通信。 那些对象没有实现 Observable . 我的 Dart 聚合物对象看起来像: @CustomTag('user-
在 java swing 项目中,我有一个模型类,它保存某个 JPanel 的状态。我需要使这些数据可供 View 使用。我认为有两种选择。有一个扩展 Observable 的类并将模型作为实例变量。
我想找到一种方法来检测观察者是否已完成使用我使用 Rx.Observable.create 创建的自定义可观察对象,以便自定义可观察对象可以结束它并正确地进行一些清理。 因此,我创建了一些测试代码,如
我正在尝试查询数据库。迭代结果列表,并为每一项再执行一个请求。在 rxjs 构建结束时,我有 Observable[]> 。但我需要Observable 。如何做到这一点? this.caseServ
我希望我的 api 上有一个方法返回 Observable> 但我希望该方法中的代码知道所有包含的 Observables 是否已完成,以便它可以关闭某些内容。最好的方法是什么? 更明确地说,我希望完
我有两个方法返回 Observable> firstAPI.getFirstInfo("1", "2"); secondApi.getSecondInfo(resultFirstObservable,
我有一个 Observable返回单个 Cursor实例(Observable)。我正在尝试利用 ContentObservable.fromCursor获取 onNext 中每个游标的行回调。 我想
我有两种返回 Observable 的方法: Observable firstObservable(); Observable secondObservable(String value); 对于第一
我正在尝试创建一个将用户数据作为 Observable 的函数,并使用来自第一个 observable 的数据从查询中添加/合并数据,然后将所有这些数据作为一个 observable 返回,我可以这样
我有一个 spec-compliant ECMAScript Observable ,具体来自 wonka library .我正在尝试将这种类型的 observable 转换为 rxjs 6 obs
为了简化问题,我在这里使用了数字和字符串。代码: const numbers$:Observable = of([1,2,3]); const strings: string[] = ["a","b"
对于我的 Android 应用程序,我需要一个 Observable 来聚合来自 7 个不同搜索的结果并作为一个集合发出。 对于最终发射,我选择了 ListMultimap其中 Content是搜索结
我正在使用改造 2.0.0-beta2 并且调试构建工作正常,但我在使用 Proguard 发布构建时遇到以下错误。 这是更新后的 logcat 错误。 11-17 18:23:22.751 1627
observer.throw(err) 和 observer.error(err) 有什么区别? 我正在使用 RxJS 版本“5.0.0-beta.12” var innerObservable =
我们有一种情况,对服务的方法调用返回一个 IObservable但我们的客户期望 IObservable .将 T1 转换为 T2 很简单。 Rx 中有什么允许这样做的吗? (即链接观察者) 我知道我
我陷入了如何将以下可观察类型转换/转换为我的目标类型的困境: 我有可观察的类型: Observable>> 我想将其转换为: Observable> 所以当我订阅它时,它会发出 List不是Obser
我是一名优秀的程序员,十分优秀!