 
         dataLoader = MockDataLoader()
         imageCache = MockImageCache()
+        observer = ImagePipelineObserver()
         dataCache = MockDataCache()
 
-        pipeline = ImagePipeline {
+        pipeline = ImagePipeline(delegate: observer) {
             $0.dataLoader = dataLoader
             $0.imageCache = imageCache
             $0.dataCache = dataCache

    var dataLoader: MockDataLoader!
    var imageCache: MockImageCache!
    var dataCache: MockDataCache!
    var pipeline: ImagePipeline!
    var image: FetchImage!


        image.pipeline = pipeline
    }

    func testImageLoaded() throws {
        // RECORD
        let record = expect(image.$result).toPublishSingleValue()

        // WHEN
        image.load(Test.request)
