interface CompletionObserverimport { type CompletionObserver } from "https://deno.land/x/rxjs@v1.0.2/mod.ts"; Type ParametersTPropertiesoptionalclosed: booleanoptionalnext: (value: T) => voidoptionalerror: (err: any) => voidcomplete: () => void