RxJavaString

RxJavaString copied to clipboard

Documentation example of split doesn't work

4

I wasn't super sure I was following your test functions so I just tested the observables by transforming them to and from arrays. Part of the problem is StringObservable.split() seems...

JakeCB

Split package makes this module pretty much unusable in OSGi

2

The StringObservable is in the same package as the regular Observable (rx.observables), so it isn't possible to import the package effectively. Would it make sense to put it in its...

flyaruu

What does StringObservableTest.testFromReaderWillUnsubscribeBeforeCallingNextRead() test?

1

I looked at the following test: ``` @Test public void testFromReaderWillUnsubscribeBeforeCallingNextRead() { final byte[] inBytes = "test".getBytes(); final AtomicInteger numReads = new AtomicInteger(0); ByteArrayInputStream is = new ByteArrayInputStream(inBytes) { @Override...

suchafreak

StringObservable.decode should call onError when buffer not empty on completion

4

At the moment if `StringObservable.decode` is called on a stream of `byte[]` and the source stream completes with bytes left over in the buffer (more is required before a string...

davidmoten