aretherecookies-mobile/js/streams/FoodItemsStream.js

//@flow
import { createFoodItem } from '../records/FoodItemRecord';
import { setById } from '../helpers/ImmutableHelpers';
import { Map } from 'immutable';
import location$ from './LocationStream';
import { getFoodItemsForLocation, type FoodItemsForLocation } from '../apis/FoodItemsApi';

export default location$
	.mergeMap(pos => getFoodItemsForLocation({ pos }))
	.map(({ fooditems = [] }: FoodItemsForLocation) => {
		return fooditems.map(createFoodItem).reduce(setById, new Map());
	});