import { Operation } from '@effection/core' ; import { once } from './once' ; import { EventSource } from './event-source' ; param source export function * throwOnErrorEvent ( source ) { let error = yield once ( source , 'error' ) ; throw error ; }