scala socket examples
some rx example code