mirror of
https://github.com/Start9Labs/patch-db.git
synced 2026-03-26 18:31:53 +00:00
14 lines
430 B
TypeScript
14 lines
430 B
TypeScript
import { Observable } from "rxjs";
|
|
import { map } from "rxjs/operators";
|
|
import { Update } from "../types";
|
|
import { Source } from "./source";
|
|
import { RPCResponse } from "./ws-source";
|
|
|
|
export class MockSource<T> implements Source<T> {
|
|
constructor(private readonly seed: Observable<Update<T>>) {}
|
|
|
|
watch$(): Observable<RPCResponse<Update<T>>> {
|
|
return this.seed.pipe(map((result) => ({ result, jsonrpc: "2.0" })));
|
|
}
|
|
}
|