RxIo
RxIo copied to clipboard
javasync
Asynchronous non-blocking File Reader and Writer library for Java
This looks to work fine: ```java Flow.Publisher body = BodyPublishers.ofFile(metamorphosis); Observable .fromPublisher(FlowAdapters.toPublisher(body)) .take(10) .map(buf -> new String(buf.array())) .zipWith(Observable.interval(500, TimeUnit.MILLISECONDS), (item, interval) -> item) .subscribe(str -> System.out.println(str)); System.out.println("Subscribed"); ```
I think NewlineIterator is useless. Check this: https://stuartmarks.wordpress.com/2020/04/14/scanner-is-a-weird-but-useful-beast/
This method was intended for an unbounded `Observable` without backpressure. Thus we should implement it based on `Observable` of RxJava rather than `Publisher`. And then maybe latter we may convert...