Function callSubscriber

src/dispatcher.js:5–15

(type, fn, event)

import {concat, findByPred, remove, contains} from './utils/collections'

function callSubscriber(type, fn, event) {
  if (type === ANY) {
    fn(event)
  } else if (type === event.type) {
    if (type === VALUE || type === ERROR) {
      fn(event.value)
    } else {
      fn()
    }
  }
}

function Dispatcher() {
  this._items = []