aretherecookies-mobile/js/streams/CreateFoodItemStream.js

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

type CreateFoodItemState = {
	foodItem: FoodItemRecord,
	loading: boolean,
	error?: ?Error,
};

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

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

emitter({ foodItem: new FoodItemRecord(), loading: false, error: null });

export default multicaster;