interface NextObserverimport { type NextObserver } from "https://deno.land/x/rxjs@v1.0.2/mod.ts"; OBSERVER INTERFACES Type ParametersTPropertiesoptionalclosed: booleannext: (value: T) => voidoptionalerror: (err: any) => voidoptionalcomplete: () => void