package Ġru . gu ar 7 3 8 7 3 . rx j avas ample Ċ Ċ import Ġandroid . util . Log Ċ import Ġrx . Observable Ċ Ċ public Ġfun Ġrx Java Test () Ġ{ ĊĠĠĠ ĠObservable . just < String >(" Hello ", Ġ" World ", Ġ" From ĠArt ur ", Ġ" And ĠN PP Ġteam ", Ġ" With Ġlove ") ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. take ( 4 ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. map < Int >({ Ġs Ġ-> Ġs . length () Ġ}) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. filter ({ Ġi Ġ-> Ġi Ġ> Ġ 5 Ġ}) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. repeat ( 2 ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. flatMap < Int >({ Ġi Ġ-> ĠObservable . just ( i Ġ+ Ġ 5 , Ġi Ġ+ Ġ 1 0 , Ġi Ġ+ Ġ 1 5 ) Ġ}) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe ( Ġ{ Ġi Ġ-> ĠLog . i (" rx Java Kotlin Text ", Ġ"" Ġ+ Ġi )}) Ċ } ĊĊ