hmole
publish { source -> Observable.concat( source.take(1), source.sample(period, unit, scheduler) ) }