gistfile1.swift

publc func createLoginproducer(username:String, 
                               password:String) -> SignalProducer<UserState, LoginError> {
  
  // Define processor here.
  return createInternalLoginProducer(username:username, password:password, loginStateProcessor:determineLoginStateTest, userStateProcessor:determineUserStateTest)

}


public func createInternalLoginProducer(username : String, 
                                        password : String, 
                                      loginState : (String, String, (NSURLRequest, NSHTTPURLResponse?, AnyObject?, NSError?) -> ())->(), 
                                       userState : (String, (NSURLRequest, NSHTTPURLResponse?, AnyObject?, NSError?)->Void) -> ())
                                -> SignalProducer<UserState, LoginError> {

    return SignalProducer { sink, disposable in
     
       func process(request : NSURLRequest, response : NSHTTPURLResponse?, data : AnyObject?, error : NSError?) {
           switch processResponseWithData(response, data, error) {
           case .Success(let box) :
               sendNext(sink, box.unbox)
           case .Failure(let e) :
               sendError(sink, e.unbox)
           }
       }
       
       loginState(username, password, process)
    } |> tryMap(validateServerError) |> tryMap(validateLogin) |> tryMap(parseLoginJSON) |> joinMap(.Concat, createUserInformationProducer) |> tryMap(userState) |> mapError(loginErrorFromStoreError)  
}