All of the flattening map operators weren't respecting pulls on cold sources. More care needs to go into when a flattening map operator can pull on the source or on inner sources to prevent overflowing (infinite pulls from either inner sources or the outer source) or double pulling.
All of the flattening map operators weren't respecting pulls on cold sources. More care needs to go into when a flattening map operator can pull on the source or on inner sources to prevent overflowing (infinite pulls from either inner sources or the outer source) or double pulling.