private <T> Observable<T> handleError(Record record, Errors error, Throwable ex, boolean passable) {
    """
	Aggregates errors that occur during the processing of a batch.
	
	@param record the record being written
	@param error the error encountered while writing the record
	@param ex the exception encountered while writing the record
	@param passable whether the record can be optionally passed down the pipeline
	@return an empty observable
    """
    errors.put(record, new ErrorRecord(error, ex, passable));
    return Observable.empty();
  }
private <T> Observable<T> handleError(Record record, Errors error, Throwable ex, boolean passable) {
    errors.put(record, new ErrorRecord(error, ex, passable));
    return Observable.empty();
  }
private < T > Observable < T > handleError ( Record record , Errors error , Throwable ex , boolean passable ) { errors . put ( record , new ErrorRecord ( error , ex , passable ) ) ; return Observable . empty ( ) ; }
Aggregates errors that occur during the processing of a batch.

@param record the record being written
@param error the error encountered while writing the record
@param ex the exception encountered while writing the record
@param passable whether the record can be optionally passed down the pipeline
@return an empty observable
Aggregates errors that occur during the processing of a batch .