just运算
2016-03-15 本文已影响13人
幸运的小强本人
just图标说明如下:
![](https://img.haomeiwen.com/i958801/dd2e58aae979154e.png)
/**
Returns an observable sequence that contains a single element.
seealso: http://reactivex.io/documentation/operators/just.html
*/
public static func just(element: E)->Observable<E> {
return Just(element: element)
}
class Just<Element>: Producer<Element> {
private let _element: Element
init(element: Element) {
_element = element
}
override func subscribe<O: ObserverType where O.E == Element>(observer: O)->Disposable {
observer.on(.Next(_element))
observer.on(.Completed)
return NopDisposable.instance
}
}