 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

            if HttpFlagChecker.isDownloadErrorFlag(statusCode) {
                let httpError = HttpError(httpCode: statusCode, context: context)
                let contextError = ErrorWithContext(error: httpError, context: #function)
                return .Failure(contextError)
            }

            return .Success(response)
        }
    }



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

        return AsyncStream { observer -> Disposable in

            let stream = chunkedDataStream(params)

