基本概念

每个Observable队列都仅仅是一个简单的队列，Observable比Swift中的SequenceType优秀在于它能接受异步的元素，这是RxSwift的核心概念。

Event

队列的语法： Next* (Error | Completed)?

Event是一个泛型枚举，一个队列中可以有0个或者多个Next元素，当队列中出现Error和Completed元素时，队列将不再接受Next元素。

enum Event<Element>  {
    case Next(Element)
    case Error(ErrorType)
    case Completed
}

创建一个Observable(aka observable sequence)

在Observable+Creation中，RxSwift定义了很多帮助创建Observable的方法，例如create, empty, never, just, error, of, deferred, generate, repeatElement和using, 以及对SequenceType和Array的扩展方法toObservable。

func myJust<E>(element: E) -> Observable<E> {
    return Observable.create { observer in
        observer.on(.Next(element))
        observer.on(.Completed)
        return NopDisposable.instance
    }
}

这里通过尾随闭包(Trailing Closures)来创建了一个Observable，create方法的定义是：

public static func create(subscribe: (AnyObserver<E>) -> Disposable) -> Observable<E> {
    return AnonymousObservable(subscribe)
}

这里subscribe其实是一个handler，接受一个Observer，返回一个Disposable对象，并作为AnonymousObservable的init参数传入。AnyObserver<Element>实现了ObserverType协议，我们在该handler内，将Event通过on发送到队列中去，最后返回的Disposable，Disposable在Observable被subscribe后被返回，用作Observable的终止。

订阅一个Observable

在Observable被创建后，我们会得到一个Observable，它实现了ObservableType协议，在Observable+Extensions中，可以发现一些用于订阅的方法：subscribe, subscribeNext, subscribeError和subscribeCompleted。被创建的Observable是不会执行任何代码的，因为它只定义了Observable怎么被创建起来，只有在它被subscribe之后，队列才会真正被创建。

public func subscribeNext(onNext: (E) -> Void) -> Disposable {
    let observer = AnonymousObserver<E> { e in
      if case .Next(let value) = e {
        onNext(value)
      }
    }
    return self.subscribeSafe(observer)
}

Observable的终止

在一个subscription上调用dispose将终止一个被观察的队列，在create时定义的Disposable的销毁代码会被执行。

生命周期

在基本概念中，我们接触到了Event，Observable和Observer，他们的生命周期如图所示：

RxSwift life cycle

本节仅介绍了RxSwift中几个重要的概念和他们是怎么协同工作的，下一节将细化Observable的transform, filter和combine。