Bacon.js поток с некоторыми хорошими ошибками

Question

Результат операции PUT против базы данных, иногда нормально, даже если он не возвращается как код HTTP 200.

В этом конкретном случае я хочу обрабатывать 400 как еще одну хорошую ошибку, но изо всех сил пытаюсь придумать элегантный способ сделать это.

# stream from a promise any non 200 is fail 
putter = Bacon.fromPromise @_exec 'PUT', '/some/resource', {} 
errors = putter.errors().mapError(errBody) # now errors are normal values 
badErrors = errors.filter(statusIsnt(400)).flatMap (body) -> 
    return new Bacon.Error body     # and now they are errors again 
okErrors = errors.filter(statusIs(400)).flatMap (body) -> {} 
noError = putter.mapError().filter (v) -> v? # attempt to get rid of errors 
Bacon.mergeAll noError, okErrors, badErrors # combine to get result stream 

Я родом из фона обещания, и я считаю, выше несколько неуклюжие, что приводит меня к выводу, что я что-то не хватает. Сравните:

@_exec 'PUT', '/some/resource', {} 
.fail (err) -> 
    if err.body.status == 400 # ok 
    return {} 
    else 
    throw err 

Answer 1

Вы можете использовать withHandler с Bacon.Error для throw и (неявным) Bacon.Next для result. Но код будет очень похож на вашу обработку уже в обещании. На самом деле обедневная версия имеет меньше шаблонов.

Сравните свое обещание версию

promise = @_exec('PUT', '/some/resource', {}) 
recovered = promise.fail (err) -> 
    # 400 is ok. make it ok already in promise 
    if err?.body?.status == 400 then {} else throw err.body 
result = Bacon.fromPromise recovered 

и withHandler бекон «только» версии

promise = @_exec('PUT', '/some/resource', {}) 
stream = Bacon.fromPromise promise 
result = stream.withHandler (event) -> 
    if (event.hasValue()) 
    @push(event) 
    else 
    # error 
    if event.error?.body?.status == 400 then 
     @push({}) 
    else 
     @push(event) 

Answer 2

Одно из возможных решений для этого конкретного сценария, чтобы изменить результат уже в обещании, но я могу легко предусмотреть случаи, когда вы не можете сделать это.

Bacon.fromPromise @_exec('PUT', '/some/resource', {}).fail (err) -> 
    # 400 is ok. make it ok already in promise 
    if err?.body?.status == 400 then {} else throw err.body 

Должен быть лучший функциональный подход к этой проблеме?

Answer 3

withHandler является основным методом, который позволяет работать на событиях всех типов. В нем вы можете вызвать @push, который отправит ошибки в поток ошибок и значения в значение streeam. Возможно, следующее:

Bacon.fromPromise(@_exec('PUT', '/some/resource', {})) 
    .withHandler((event) -> 
     if event.isError && event.error.body?.status? == 400 
      @push(new Bacon.Next({})) 
     else 
      @push(event) 
    )