Use scheduler when making new observable