new streams should be linked to the domain

es.pipeline & es.through are creating new streams. Those were inheriting from the current domain
which is not the internal one. This could cause errors to bubble up to an user's domain instead of
the internal one. Fix this behaviour by using the internal domain while creating new streams.