Observable Linq query implementation.