Refactored extraction of client address.
Added tests for RxJava observable encoder.