В учебниках по Java RX я вижу:
Observable<String> observable = Observable.just("Hello");
observable.subscribe(s -> result = s);
assertTrue(result.equals("Hello"));
или что-то в этом роде: 
Я понимаю эти учебники, но у меня проблемы смоя задача.У меня 2 класса: первый класс должен играть заметную роль, второй - наблюдатель.Как я могу заставить Observer слушать Observable с помощью Java RX.Буду благодарен, если вы разместите небольшой пример кода.Спасибо ..