The problem is, _streamFactoryWrapper captures reference to itself, instead of the previous value of _streamFactoryWrapper. 

It can be easily fixed by replacing

_streamFactoryWrapper = inner => wrapper(_streamFactoryWrapper(inner));

with

_streamFactoryWrapper = inner => wrapper(_streamFactoryWrapper(inner));