Hi, guys, a question.
I am going to wrap a callback from socket connection into a functional data structure.
From RxJava’s point of view, i would create a Subject, one end will be listening, and to another end i will be emitting items.
Is there some typeclass in arrow that gives me similar thing?
Of course, i can still create a subject, then wrap it to ObservableK, just wanted to make sure i don’t miss some functional paradigm, because i am still pretty new to it.
Or where can i read some articles about that approach - that will also help.
Thanks!