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


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

        return create(producer: { observer -> Disposable in

            let stream = chunkedDataStream(params)


import Foundation

import iAsync_utils
import struct iAsync_reactiveKit.AsyncStream
import func iAsync_reactiveKit.create
import func iAsync_reactiveKit.createStream
