import { type Subscriber } from "https://deno.land/x/rsocket@0.3.0/reactivestreams/mod.ts";
Methods
onSubscribe(subscription: Subscription): void
onNext(value: T): void
Latest
import { type Subscriber } from "https://deno.land/x/rsocket@0.3.0/reactivestreams/mod.ts";