Subscription with MPSC receiver in context data

[PainOchoco]

Hello there,

I'm trying to make a subscription with a MPSC channel by passing the channel's receiver in async_graphql's context data.
However, the ctx.data only provides reference to objects, how could I get the rx receiver directly?

Here's a small example:

use async_graphql::{self, Context, Subscription};
use futures::{channel::mpsc::Receiver, stream::Stream};

#[derive(Default)]
pub struct SomeSubscription;

#[Subscription]
impl SomeSubscription {
    async fn something(&self, ctx: &Context<'_>) -> impl Stream<Item = i32> {
        let rx = ctx.data::<Receiver<i32>>().unwrap();
        // rx is a &Receiver<i32>, what to do?!
    }
}

Is there another way to do this?
Please let me know how should i go about that!