interface Publisherimport { type Publisher } from "https://deno.land/x/rsocket@0.3.0/reactivestreams/mod.ts"; Type ParametersTMethodssubscribe(subscriber: Subscriber<T>): void