Add rxjava and make document stream into Observable