     }
 }
 
-public extension AsyncStreamType where Next == NetworkProgress {
+public extension AsyncStream where Next == NetworkProgress {
 
     public func netMapNext() -> AsyncStream<Value, AnyObject, Error> {
         return mapNext { info -> AnyObject in

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

            return stream.observe { event -> () in

                switch event {
                case .success(let value):
                    let result = NetworkResponse(params: params, response: value, responseData: responseData)
                    observer(.success(result))
                case .next(let chunk):
                    switch chunk {
                    case .Download(let info):
                        responseData.appendData(info.dataChunk)
                    case .Upload:
                        break
                    }
                    observer(.next(chunk))
                case .failure(let error):
                    observer(.failure(error))
                }
            }
        }
    }

    public static func dataStream(url: NSURL, postData: NSData?, headers: URLConnectionParams.HeadersType?) -> NetworkStream {
