RxJS.Subscriber

type Subscriber a = { completed :: forall e. Unit -> Eff e Unit, error :: forall e. Error -> Eff e Unit, next :: forall e. a -> Eff e Unit }