无法为规范文件中的 http-get 请求“订阅”到“Observable”
Unable to `subscribe` to `Observable` for http-get request in spec file
我想测试以下 return 可观察的服务:
public getData(str:string) {
// return an observable
return this.http.get(‘calltoserviceapi’+str)
.map( (responseData) => {
return responseData.json().Abc;
})
.map((s: Array<any>) => {
let result:Array<AbcModel> = [];
if (s) {
s.forEach((s) => {
result.push(
new AbcModel(s.Val1,
s.Val2,
));
});
}
return result;
});
}
我的规格文件:
fdescribe ("my-service.spec.js", ()=> {
beforeEachProviders(() => [
MyService,
BaseRequestOptions,
MockBackend,
provide(Http, {
useFactory: (backend: MockBackend, defaultOptions: BaseRequestOptions) => {
return new Http(backend, defaultOptions);
},
deps: [MockBackend, BaseRequestOptions]
}),
provide(XHRBackend, {useClass: MockBackend})
]);
fit('should get response',inject([XHRBackend, MyService], (mockBackend, service) => {
console.log("inside fit");
let response = "something returned from service";
let responseOptions = new ResponseOptions({ body: response });
mockBackend.connections.subscribe((connection: MockConnection) => {
connection.mockRespond(new Response(responseOptions));
});
service.getData('xyz').subscribe((a: MyModel[]) => {
expect(a.length).toBe(11); //this is NOT failing
expect(a).toContain(“something”);
}); //debugger not going inside subscribe
}));
调试时,订阅方法没有执行。结果,我的测试用例在没有执行的情况下通过了。我错过了什么?
P.S : MyService 目前不在 used/called 组件内部。
我认为你需要添加 async(...)
fit('should get response',async(inject([XHRBackend, MyService], (mockBackend, service) => {
让测试等到所有异步任务完成。否则 http.get()
任务被安排,然后测试结束。
我终于想出了解决办法。我做了两处更改:
- 使用
async()
@Gunter 指出的
- 将通过的响应字符串化。
这是代码:
fit('should get response',async(inject([XHRBackend, MyService], (mockBackend, service) => { //<--- wrap inside async call
console.log("inside fit");
let response = "something returned from service";
let responseOptions = new ResponseOptions({ body: JSON.stringify(response) }); //<--- stringify the response
mockBackend.connections.subscribe((connection: MockConnection) => {
connection.mockRespond(new Response(responseOptions));
});
service.getData('xyz').subscribe((a) => {
expect(a.length).toBe(11); //will fail
expect(a).toContain(“something”); //will pass
});
})));
我想测试以下 return 可观察的服务:
public getData(str:string) {
// return an observable
return this.http.get(‘calltoserviceapi’+str)
.map( (responseData) => {
return responseData.json().Abc;
})
.map((s: Array<any>) => {
let result:Array<AbcModel> = [];
if (s) {
s.forEach((s) => {
result.push(
new AbcModel(s.Val1,
s.Val2,
));
});
}
return result;
});
}
我的规格文件:
fdescribe ("my-service.spec.js", ()=> {
beforeEachProviders(() => [
MyService,
BaseRequestOptions,
MockBackend,
provide(Http, {
useFactory: (backend: MockBackend, defaultOptions: BaseRequestOptions) => {
return new Http(backend, defaultOptions);
},
deps: [MockBackend, BaseRequestOptions]
}),
provide(XHRBackend, {useClass: MockBackend})
]);
fit('should get response',inject([XHRBackend, MyService], (mockBackend, service) => {
console.log("inside fit");
let response = "something returned from service";
let responseOptions = new ResponseOptions({ body: response });
mockBackend.connections.subscribe((connection: MockConnection) => {
connection.mockRespond(new Response(responseOptions));
});
service.getData('xyz').subscribe((a: MyModel[]) => {
expect(a.length).toBe(11); //this is NOT failing
expect(a).toContain(“something”);
}); //debugger not going inside subscribe
}));
调试时,订阅方法没有执行。结果,我的测试用例在没有执行的情况下通过了。我错过了什么?
P.S : MyService 目前不在 used/called 组件内部。
我认为你需要添加 async(...)
fit('should get response',async(inject([XHRBackend, MyService], (mockBackend, service) => {
让测试等到所有异步任务完成。否则 http.get()
任务被安排,然后测试结束。
我终于想出了解决办法。我做了两处更改:
- 使用
async()
@Gunter 指出的
- 将通过的响应字符串化。
这是代码:
fit('should get response',async(inject([XHRBackend, MyService], (mockBackend, service) => { //<--- wrap inside async call
console.log("inside fit");
let response = "something returned from service";
let responseOptions = new ResponseOptions({ body: JSON.stringify(response) }); //<--- stringify the response
mockBackend.connections.subscribe((connection: MockConnection) => {
connection.mockRespond(new Response(responseOptions));
});
service.getData('xyz').subscribe((a) => {
expect(a.length).toBe(11); //will fail
expect(a).toContain(“something”); //will pass
});
})));