I get data normalization exception if I try to create stream with path that contains predicates.

Also it will be helpful to be able to subscribe to leaves.