监听器是在等候，或有能力等候来自信号的事件的任何东西。监听器用可以接受事件（Event）的Observer类型表示。

监听器可以使用回调版本的Signal.observe或者SignalProducer.start方法隐性创建。

—— ReactiveCocoa 框架概览

其实，监听器就是一个函数（function）：Event<Value, Error> -> ()。在监听器内部，这个函数叫做action。它接收一个事件对之进行处理：

public struct Observer<Value, Error: ErrorType> {
    public typealias Action = Event<Value, Error> -> ()

    public let action: Action

    public init(_ action: Action) {
        self.action = action
    }

    public init(failed: (Error -> ())? = nil, completed: (() -> ())? = nil, interrupted: (() -> ())? = nil, next: (Value -> ())? = nil) {
        self.init { event in
            switch event {
            case let .Next(value):
                next?(value)

            case let .Failed(error):
                failed?(error)

            case .Completed:
                completed?()

            case .Interrupted:
                interrupted?()
            }
        }
    }

    ......
}

监听器的初始化方法有两个，一个很直观，一个稍微复杂一些。不过目的都一样：你决定如何分别处理四种类型的事件，初始化方法把这个决定存在监听器里。

监听器的构成

2. 如何向监听器发送事件

取得监听器的引用后，可以用以下四个方法发送事件：

1. sendNext(value: Value)
2. sendFailed(error: Error)
3. sendComplete()
4. sendInterrupted()

发送事件，其实就是将事件的值（发送Next事件时）或错误（发送Failed事件时）作为参数调用监听器的action：

public struct Observer<Value, Error: ErrorType> {
    
    ......

    /// Puts a `Next` event into the given observer.
    public func sendNext(value: Value) {
        action(.Next(value))
    }

    /// Puts an `Failed` event into the given observer.
    public func sendFailed(error: Error) {
        action(.Failed(error))
    }

    /// Puts a `Completed` event into the given observer.
    public func sendCompleted() {
        action(.Completed)
    }

    /// Puts a `Interrupted` event into the given observer.
    public func sendInterrupted() {
        action(.Interrupted)
    }
}

向监听器发送事件