HotObservableToy Sample code for the Hot Observable purejava.ContinuousBroadcaster It will send per second the current time in String format. rxstyle.RxContinuousBroadcaster It generates the Observable to send per second current time in String format.