こうやると非同期で動くけど（当たり前）　sinkが発動しない（意味不明） #CodePiece

CodePiece.swift

(0...3)
    .map { i -> AnyPublisher<Int, Never> in
        
        Future<Int, Never> { promise in
            
            DispatchQueue.global().async {
                print("start", i, "----", Thread.current)
                sleep(UInt32([0, 2, 3, 5].randomElement()!))
                print("end", i)
                
                promise(.success(i * 2))
            }
        }
        .eraseToAnyPublisher()
    }
    .reduce(Empty<Int, Never>().eraseToAnyPublisher()) { (p, pp) in
        
        p.merge(with: pp).eraseToAnyPublisher()
    }
    .sink { (i) in
        print(i)
    }