OperatorAny needs to handle backpressure