 import Foundation
 
 import iAsync_utils
-import protocol iAsync_reactiveKit.AsyncStreamType
 import struct iAsync_reactiveKit.AsyncStream
 import func iAsync_reactiveKit.create
 import func iAsync_reactiveKit.createStream


    public static func dataStream(params: URLConnectionParams) -> NetworkStream {

        return create(producer: { observer -> Disposable in

            let stream = chunkedDataStream(params)



            let result = downloadStatusCodeResponseAnalyzer(params)(response.response)
            switch result {
            case .failure(let error):
                return .failure(error)
            case .Success:
                return .success(response)
            }
        }
    }
