ObservableStore.swift

import ReactiveCocoa
import ReSwift
import Result

class ObservableStore<State: StateType>: Store<State> {
	
	internal let observable: MutableProperty<State>
	
	var producer: SignalProducer<State, NoError> {
		get {
			return observable.producer
		}
	}
	
	var signal: Signal<State, NoError> {
		get {
			return observable.signal
		}
	}
	
	override var state: State! {
		didSet {
			observable.value = state
		}
	}
	
	convenience init(reducer: AnyReducer, state: State) {
		self.init(reducer: reducer, state: state, middleware: [])
	}
	
	required init(reducer: AnyReducer, state: State, middleware: [Middleware]) {
		observable = MutableProperty<State>(state)
		super.init(reducer: reducer, state: state, middleware: middleware)
	}
	
	func dispatch(producer: SignalProducer<ReSwift.Action, NoError>) {
		producer.startWithNext { [unowned self] in
			self.dispatch($0)
		}
	}
	
	func dispatch(signal: Signal<ReSwift.Action, NoError>) {
		signal.observeNext { [unowned self] in
			self.dispatch($0)
		}
	}
}

An example usage instead of using subscribe and unsubscribe would be to just call store.producer.subscribeNext any time that we need data, that way we don't need to be in a delegated model specifically.