observable word count
rxjava-scala version 0.16.1 has new API