processObservables

fun processObservables(risLineObservable: Observable<String>): Observable<RisRecord>

Converts an observable of Strings (representing lines in a RIS file) into an observable of RisRecords in non-blocking manner. May throw KRisException if the line flow cannot be parsed successfully.