Hi, guys, a question. I am going to wrap a callba...
# arrow
k
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!