method DefaultQueueProcessor.prototype.onSubscribeimport { DefaultQueueProcessor } from "https://deno.land/x/rsocket@0.3.0/reactivestreams/mod.ts"; onSubscribe(subscription: Subscription): voidParameterssubscription: SubscriptionReturnsvoid