tests added

Author: kptfh

json-nonblocking/src/test/java/reactivejson/TokenizerTest.java

@@ -219,6 +219,19 @@ private void testTokenize(List<String> source, List<String> expected, boolean to
 		}
 	}
 
+	@Test
+	public void shouldReadSequence() {
+		testTokenize(
+				asList("{\"foo\": \"foofoo1\", \"bar\": \"barbar1\"}", "{\"foo\": \"foofoo2\", \"bar\": \"barbar2\"}"),
+				asList("{\"foo\": \"foofoo1\", \"bar\": \"barbar1\"}", "{\"foo\": \"foofoo2\", \"bar\": \"barbar2\"}"),
+				true);
+
+		testTokenize(
+				asList("{\"foo\": \"foofoo1\", \"bar\": \"barbar1\"}", "{\"foo\": \"foofoo2\", \"bar\": \"barbar2\"}"),
+				asList("{\"foo\": \"foofoo1\", \"bar\": \"barbar1\"}", "{\"foo\": \"foofoo2\", \"bar\": \"barbar2\"}"),
+				false);
+	}
+
 	private ByteBuffer stringBuffer(String value) {
 		return ByteBuffer.wrap(value.getBytes(StandardCharsets.UTF_8));
 	}

json-reactor/src/test/java/reactivejson/ReactorObjectReaderTest.java

@@ -10,6 +10,7 @@
 import reactor.core.publisher.Mono;
 import reactor.test.StepVerifier;
 
+import java.io.UncheckedIOException;
 import java.nio.ByteBuffer;
 import java.nio.charset.StandardCharsets;
 import java.util.ArrayList;
@@ -51,6 +52,31 @@ public void shouldReadElements() throws JsonProcessingException {
 				.verifyComplete();
 	}
 
+	@Test
+	public void shouldReadSequence() {
+		TestEntity[] testEntities = new TestEntity[]{
+				new TestEntity(1, "testName1"),
+				new TestEntity(3, "testName3"),
+				new TestEntity(7, "testName7")};
+
+		Publisher<ByteBuffer> byteBuffers = Flux.fromArray(testEntities)
+				.flatMap(testEntity -> {
+					try {
+						return stringBuffer(objectMapper.writeValueAsString(testEntity));
+					} catch (JsonProcessingException e) {
+						throw new UncheckedIOException(e);
+					}
+				}) ;
+
+		Flux<TestEntity> testEntityRed = reader.readElements(byteBuffers, objectMapper.readerFor(TestEntity.class));
+
+		StepVerifier.create(testEntityRed)
+				.expectNextMatches(testEntity -> testEntity.equals(testEntities[0]))
+				.expectNextMatches(testEntity -> testEntity.equals(testEntities[1]))
+				.expectNextMatches(testEntity -> testEntity.equals(testEntities[2]))
+				.verifyComplete();
+	}
+
 	@Test
 	public void shouldReadElementsAsArray() throws JsonProcessingException {
 		TestEntity[] testEntities = new TestEntity[]{

json-rx2/src/test/java/reactivejson/Rx2ObjectReaderTest.java

@@ -47,6 +47,23 @@ public void shouldReadElements() throws JsonProcessingException {
 				.assertResult(testEntities);
 	}
 
+	@Test
+	public void shouldReadSequence() {
+		TestEntity[] testEntities = new TestEntity[]{
+				new TestEntity(1, "testName1"),
+				new TestEntity(3, "testName3"),
+				new TestEntity(7, "testName7")};
+
+		Publisher<ByteBuffer> byteBuffers = Flowable.fromArray(testEntities)
+				.flatMap(testEntity -> stringBuffer(objectMapper.writeValueAsString(testEntity)));
+
+		Flowable<TestEntity> testEntityRed = reader.readElements(byteBuffers,
+				objectMapper.readerFor(TestEntity.class));
+
+		testEntityRed.test()
+				.assertResult(testEntities);
+	}
+
 	@Test
 	public void shouldReadElementsAsArray() throws JsonProcessingException {
 		TestEntity[] testEntities = new TestEntity[]{