         }
     }
 
-    func testMap_WhenFutureStreamSuccedsAndFlatMapFails_FlatMapCalledCompletesWithError() {
+    func testFlatMap_WhenFutureStreamSuccedsAndFlatMapFails_FlatMapCalledCompletesWithError() {
         let promise = StreamPromise<Bool>()
         let stream = promise.stream
         let onSuccessExpectation = XCTExpectFullfilledCountTimes(2, message:"onSuccess future")


    // MARK: - flatMap -

    func testMap_WhenFutureStreamAndFlatMapSucceed_FlatMapCalledCompletesSuccessfully() {
        let promise = StreamPromise<Bool>()
        let stream = promise.stream
        let onSuccessExpectation = XCTExpectFullfilledCountTimes(2, message:"onSuccess future")

        }
    }

    func testFlatMap_WhenFutureStreamFails_FlatMapNotCalledCompletesWithError() {
        let promise = StreamPromise<Bool>()
        let stream = promise.stream
        let onFailureExpectation = XCTExpectFullfilledCountTimes(2, message:"onFailure future")
