Node streams interface to observ, observ-struct and observ-array