function observableToPublisherimport { observableToPublisher } from "https://deno.land/x/rsocket@0.3.0/reactivestreams/rxjs.ts"; observableToPublisher<T>(observable: Observable<T>): Publisher<T>Type ParametersTParametersobservable: Observable<T>ReturnsPublisher<T>