@Test public void deserializeEmpty() { final StreamingDeserializer<TestPojo> deserializer = serializationProvider.getDeserializer(TestPojo.class); Iterable<TestPojo> pojos = deserializer.deserialize(EmptyBuffer.EMPTY_BUFFER); Iterator<TestPojo> pojoItr = pojos.iterator(); assertFalse(pojoItr.hasNext()); 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);  }