[Unit testing RxJS] Test complex logic with time progression syntax
with Time test Rxjs Testing unit syntax Logic
2023-09-14 09:00:45 时间
For example we have a search input:
const input$ = fromEvent(document.getElementById("#input"), "input");
input$
.pipe(
debounceTime(200),
pluck("target", "value"),
distinctUntilChanged(),
switchMap((searchTerm) => {
ajax
.getJSON(`${BASE_URL}?by_name=${searchTerm}`)
.pipe(catchError(() => EMPTY));
})
)
.subscribe();
We want to test the logic about the input box.
First thing we need to do is making it easy to mock ajax
request.
const typeahead =
(ajaxHelper = ajax) =>
(sourceObservable) => {
return sourceObservable.pipe(
debounceTime(200),
pluck("target", "value"),
distinctUntilChanged(),
switchMap((searchTerm) => {
ajaxHelper
.getJSON(`${BASE_URL}?by_name=${searchTerm}`)
.pipe(catchError(() => EMPTY));
})
);
};
input$.pipe(typeahead()).subscribe();
const { of, throwError } = require("rxjs");
const { delay } = require("rxjs/operators");
const { TestScheduler } = require("rxjs/testing");
const { typeahead } = require("..");
describe("THe typehead", () => {
beforeEach(() => {
testScheduler = new TestScheduler((actual, expected) => {
expect(actual).toEqual(expected);
});
});
it("should debounce input by 200ms", () => {
testScheduler.run((helpers) => {
const { cold, expectObservable } = helpers;
const searchTerm = "testing";
const source$ = cold("a", { a: { target: { value: searchTerm } } });
const final$ = source$.pipe(
typeahead({
getJSON: () => of(searchTerm).pipe(delay(300)),
})
);
const expected = "500ms a";
expectObservable(final$).toBe(expected, { a: searchTerm });
});
});
it("should cancel active requests if another value is emitted", () => {
testScheduler.run((helpers) => {
const { cold, expectObservable } = helpers;
const searchTerm = "testing";
const source$ = cold("a 250ms b", {
a: { target: { value: "first" } },
b: { target: { value: "second" } },
});
const final$ = source$.pipe(
typeahead({
getJSON: () => of(searchTerm).pipe(delay(300)),
})
);
const expected = "751ms b"; // 200 (debounce) + 250 (wait time) + 300 (network) + 1 (b)
expectObservable(final$).toBe(expected, { b: searchTerm });
});
});
it("should not emit duplciate values in a row", () => {
testScheduler.run((helpers) => {
const { cold, expectObservable } = helpers;
const searchTerm = "testing";
const source$ = cold("a 250ms b", {
a: { target: { value: "same" } },
b: { target: { value: "same" } },
});
const final$ = source$.pipe(
typeahead({
getJSON: () => of(searchTerm).pipe(delay(300)),
})
);
const expected = "500ms b"; // 200 (debounce) + 300 (network)
expectObservable(final$).toBe(expected, { b: searchTerm });
});
});
it("should ingore ajax errors", () => {
testScheduler.run((helpers) => {
const { cold, expectObservable } = helpers;
const searchTerm = "testing";
const source$ = cold("a 250ms b", {
a: { target: { value: "same" } },
b: { target: { value: "same" } },
});
const final$ = source$.pipe(
typeahead({
getJSON: () => throwError("error"),
})
);
const expected = ""; // in case of error, emit empty
expectObservable(final$).toBe(expected);
});
});
});
相关文章
- GLM: General Language Model Pretraining with Autoregressive Blank Infilling
- ORA-30084: invalid data type for datetime primary with time zone modifier ORACLE 报错 故障修复 远程处理
- ORA-32415: fast refreshable remote materialized view on a detail table with commit SCN-based materialized view log is not supported ORACLE 报错 故障修复 远程处理
- ORA-39251: Importing a SecureFile LOB with metadata into a scalar, column string, is not allowed. ORACLE 报错 故障修复 远程处理
- ORA-55359: unauthorized operation with policy string – string ORACLE 报错 故障修复 远程处理
- MySQL Error number: 4072; Symbol: ER_WARN_C_DISABLE_GTID_ONLY_WITH_SOURCE_AUTO_POS_INVALID_POS; SQLSTATE: HY000 报错 故障修复 远程处理
- ORA-60009: adding (string) blocks to LOB segment string.string partition string with MAXSIZE (string) ORACLE 报错 故障修复 远程处理
- ORA-00452: foreground process unexpectedly terminated with error string ORACLE 报错 故障修复 远程处理
- ORA-00488: RBAL process terminated with error ORACLE 报错 故障修复 远程处理
- ORA-00848: STATISTICS_LEVEL cannot be set to BASIC with SGA_TARGET or MEMORY_TARGET ORACLE 报错 故障修复 远程处理
- ORA-02022: remote statement has unoptimized view with remote object ORACLE 报错 故障修复 远程处理
- MySQL Error number: MY-011683; Symbol: ER_GRP_RPL_SINGLE_PRIM_MODE_NOT_ALLOWED_WITH_UPDATE_EVERYWHERE; SQLSTATE: HY000 报错 故障修复 远程处理
- MySQL Error number: MY-013149; Symbol: ER_CANT_REPLICATE_ANONYMOUS_WITH_GTID_MODE_ON; SQLSTATE: HY000 报错 故障修复 远程处理
- Linux 中的Time 函数使用指南(time函数linux)
- 语句掌握Oracle中用WITH语句的利用技巧(oracle的with)
- commandLinux下Time Command的使用指南(linux下time)
- 解析 Linux 中的段错误Note: As an AI language model I cannot guarantee the accuracy of technical information. Please consult with professional developers if you need further assistance.(段错误linux)
- Linux下Time命令实用技巧研究(linux的time命令)
- Effective Time Management with Oracle Job Scheduling(oraclejob时间)
- Boost Your Website with PHPnow MySQL for Optimal Performance!(phpnowmysql)
- Maximizing Financial Efficiency with Oracle Financial Management(oracle财务管理)
- Learn How to Check Server Time with Linux Command(linux查看服务器时间)
- Maximizing MySQL Performance with Expert Tuning Techniques(mysql性能调优)
- Optimizing Performance with a Reliable Redis Connection Pool(redispool)
- php中time()与$_SERVER[REQUEST_TIME]用法区别