added parallel stream to Observable