add conduits over TQueue for infinite streams