@Test public void deserializeSplitAcrossMultipleBuffers() { TestPojo expected1 = new TestPojo(true, (byte) -2, (short) -3, 'a', 2, 5, 3.2f, -8.5, null, new String[] {"bar", "baz"}, null); TestPojo expected2 = new TestPojo(false, (byte) 500, (short) 353, 'r', 100, 534, 33.25f, 888.5, null, new String[] {"foo"}, expected1); Buffer req1Buffer = serializePojo(expected1); Buffer req2Buffer = serializePojo(expected2); final StreamingDeserializer<TestPojo> deserializer = serializationProvider.getDeserializer(TestPojo.class); deserializeChunks(expected1, req1Buffer, deserializer); deserializeChunks(expected2, req2Buffer, deserializer); assertThat("Unexpected data remaining in deserializer", deserializer.hasData(), is(false)); }
@Override public <T> StreamingDeserializer<T> getDeserializer(final Class<T> classToDeSerialize) { return newDeserializer(mapper.readerFor(classToDeSerialize)); }
JacksonSerializationProvider implements SerializationProvider { @Override public <T> StreamingDeserializer<T> getDeserializer(final Class<T> classToDeSerialize) { return newDeserializer(mapper.readerFor(classToDeSerialize)); } }
JacksonSerializationProvider implements SerializationProvider { @Override public <T> StreamingDeserializer<T> getDeserializer(final Class<T> classToDeSerialize) { return newDeserializer(mapper.readerFor(classToDeSerialize)); } JacksonSerializationProvider();  JacksonSerializationProvider(final ObjectMapper mapper); }
JacksonSerializationProvider implements SerializationProvider { @Override public <T> StreamingDeserializer<T> getDeserializer(final Class<T> classToDeSerialize) { return newDeserializer(mapper.readerFor(classToDeSerialize)); } JacksonSerializationProvider();  JacksonSerializationProvider(final ObjectMapper mapper); @Override StreamingSerializer getSerializer(final Class<T> classToSerialize); @Override StreamingSerializer getSerializer(final TypeHolder<T> typeToSerialize); @Override StreamingDeserializer<T> getDeserializer(final Class<T> classToDeSerialize); @Override StreamingDeserializer<T> getDeserializer(final TypeHolder<T> typeToDeserialize); @Override void serialize(final T toSerialize, final Buffer destination); }
JacksonSerializationProvider implements SerializationProvider { @Override public <T> StreamingDeserializer<T> getDeserializer(final Class<T> classToDeSerialize) { return newDeserializer(mapper.readerFor(classToDeSerialize)); } JacksonSerializationProvider();  JacksonSerializationProvider(final ObjectMapper mapper); @Override StreamingSerializer getSerializer(final Class<T> classToSerialize); @Override StreamingSerializer getSerializer(final TypeHolder<T> typeToSerialize); @Override StreamingDeserializer<T> getDeserializer(final Class<T> classToDeSerialize); @Override StreamingDeserializer<T> getDeserializer(final TypeHolder<T> typeToDeserialize); @Override void serialize(final T toSerialize, final Buffer destination);  }