import { DefaultQueueProcessor } from "https://deno.land/x/rsocket@0.3.0/reactivestreams/mod.ts";
Properties
_subscriber: Subscriber<T> | undefined
Methods
onComplete(): void
onError(error: any): void
onSubscribe(subscription: Subscription): void
subscribe(subscriber: Subscriber<T>): void