Fixing FilterProcessor by replacing usage of OP.single() with Observable.error(ERROR).startWith(OP).take(1)

* This is necessary so we eagerly propagate the onNext'ed HTTP content, rather than waiting for onCompleted (as in single())
* If we hold it up, then Netty might clear it away first