Hi. I wanted to open a socket an listen to an inpu...

# rx

[bodo]

Hi. I wanted to open a socket an listen to an input stream the rx way but did not find a good example how to achieve it with correct closing the socket and input stream after the observable gets disposed. i want to use rxjava2 and found the helper function Observable.Using. Are there some good examples on how to implement this?