equal
deleted
inserted
replaced
558 } |
558 } |
559 |
559 |
560 @Override |
560 @Override |
561 public void onSubscribe(AbstractSubscription s) { |
561 public void onSubscribe(AbstractSubscription s) { |
562 this.subscription = s; |
562 this.subscription = s; |
563 parser.onSubscribe(s); |
563 try { |
|
564 parser.onSubscribe(s); |
|
565 } catch (Throwable t) { |
|
566 cf.completeExceptionally(t); |
|
567 throw t; |
|
568 } |
564 } |
569 } |
565 |
570 |
566 @Override |
571 @Override |
567 final void handle(ByteBuffer b, |
572 final void handle(ByteBuffer b, |
568 BodyParser parser, |
573 BodyParser parser, |