Function spawn_subscription

pub fn spawn_subscription<S, T>(
    sink: PendingSubscriptionSink,
    rx: S,
    permit: Option<OwnedSemaphorePermit>,
)
where
    S: Stream<Item = T> + Unpin + Send + 'static,
    T: Serialize + Send,