Read from Socket via Subscription

[Evilsmaher]

I see a lot of comments/notes inside Discussions, source page for subscriptions, and various other places, but see not actual implementation of how to listen to a socket for incoming data. Is there an example on how to do this exactly?

My personal issue is I see [Subscriptions] to be when a state is changed; how is a Socket state changed when it receives data? I'm not sure if this only applies to websockets, but I am looking to use a [Subscription] for incoming data on a tokio::TcpStream if at all possible. Any inputs?