aretherecookies-mobile/js/streams/FilterStream.js

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

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

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

export const initialFilter = new FilterRecord();

emitter(initialFilter);

export default multicaster;