Add support for changes stream