aretherecookies-mobile/js/streams/CreateProductStream.js

// @flow
import { ReplaySubject } from 'rxjs';
import ProductRecord from '../records/ProductRecord';

type CreateProductState = {
	product: ProductRecord,
	loading: boolean,
	error?: ?Error,
};

const multicaster: ReplaySubject<CreateProductState> = new ReplaySubject();

export function emitter(val: CreateProductState) {
	multicaster.next(val);
}

emitter({ product: new ProductRecord(), loading: false, error: null });

export default multicaster;