[observers] Support observable queries - a work in progress