如何使用ReplaySubject在ReactiveKit

Question

我有這樣的RxSwift：

func foo() -> Observable<Int> { 
    let subject = RxSwift.ReplaySubject<Int>.create(bufferSize: 1) 
    return subject.asObservable() 
} 

如何實現ReactiveKit同一個概念？

Answer 1

隨着ReactiveKit 3是目前處於測試階段（RK3分支），你可以這樣做：

func foo() -> Signal<Int, NoError> { 
    let subject = ReplaySubject<Int, NoError>(bufferSize: 1) 
    return subject.toSignal() 
} 

在ReactiveKit 2 ReplaySubject是廣義上的活動：

func foo() -> Stream<Int> { 
    let subject = ReplaySubject<StreamEvent<Int>>(bufferSize: 1) 
    return Stream(rawStream: subject.toRawStream()) 
} 

或

func foo() -> Operation<Int, Error> { 
    let subject = ReplaySubject<OperationEvent<Int>>(bufferSize: 1) 
    return Operation(rawStream: subject.toRawStream()) 
}