Package io.micronaut.serde.bson

Class AbstractBsonMapper

java.lang.Object

io.micronaut.serde.bson.AbstractBsonMapper

All Implemented Interfaces:

io.micronaut.json.JsonMapper, ObjectMapper

Direct Known Subclasses:

BsonBinaryMapper, BsonJsonMapper

@Internal
public abstract class AbstractBsonMapper
extends Object
implements ObjectMapper

Abstract Bson mapper.

Author:

Denis Stepanov

Nested Class Summary

Nested classes/interfaces inherited from interface io.micronaut.serde.ObjectMapper

ObjectMapper.CloseableObjectMapper

Field Summary

Fields

Modifier and Type	Field	Description
protected Deserializer.DecoderContext	decoderContext
protected Serializer.EncoderContext	encoderContext
protected final SerdeRegistry	registry
protected final @Nullable SerdeConfiguration	serdeConfiguration
protected final Class<?>	view

Constructor Summary

Constructors

Modifier	Constructor	Description
	AbstractBsonMapper(SerdeRegistry registry, SerdeConfiguration serdeConfiguration)
protected	AbstractBsonMapper(SerdeRegistry registry, SerdeConfiguration serdeConfiguration, Class<?> view)

Method Summary

Modifier and Type	Method	Description
protected abstract org.bson.BsonReader	createBsonReader(ByteBuffer byteBuffer)
protected abstract org.bson.AbstractBsonWriter	createBsonWriter(OutputStream bsonOutput)
org.reactivestreams.Processor<byte[],io.micronaut.json.tree.JsonNode>	createReactiveParser(Consumer<org.reactivestreams.Processor<byte[],io.micronaut.json.tree.JsonNode>> onSubscribe, boolean streamArray)
io.micronaut.json.JsonStreamConfig	getStreamConfig()
<T> T	readValue(byte[] byteArray, io.micronaut.core.type.Argument<T> type)
<T> T	readValue(InputStream inputStream, io.micronaut.core.type.Argument<T> type)
<T> T	readValueFromTree(io.micronaut.json.tree.JsonNode tree, io.micronaut.core.type.Argument<T> type)
<T> void	writeValue(OutputStream outputStream, io.micronaut.core.type.Argument<T> type, T object)
void	writeValue(OutputStream outputStream, Object object)
<T> byte[]	writeValueAsBytes(io.micronaut.core.type.Argument<T> type, T object)
byte[]	writeValueAsBytes(Object object)
<T> io.micronaut.json.tree.JsonNode	writeValueToTree(io.micronaut.core.type.Argument<T> type, T value)
io.micronaut.json.tree.JsonNode	writeValueToTree(Object value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.micronaut.json.JsonMapper

cloneWithViewClass, createSpecific, detectFeatures, readValue, readValue, readValue, readValue, readValue, readValueFromTree, updateValueFromTree, writeValueAsString, writeValueAsString

Methods inherited from interface io.micronaut.serde.ObjectMapper

cloneWithFeatures, writeValueAsString

Field Details

registry

protected final SerdeRegistry registry

serdeConfiguration

@Nullable
protected final @Nullable SerdeConfiguration serdeConfiguration

view

protected final Class<?> view

encoderContext

protected Serializer.EncoderContext encoderContext

decoderContext

protected Deserializer.DecoderContext decoderContext

Constructor Details

AbstractBsonMapper

public AbstractBsonMapper(SerdeRegistry registry,
 SerdeConfiguration serdeConfiguration)

AbstractBsonMapper

protected AbstractBsonMapper(SerdeRegistry registry,
 SerdeConfiguration serdeConfiguration,
 Class<?> view)

Method Details

createBsonReader

protected abstract org.bson.BsonReader createBsonReader(ByteBuffer byteBuffer)

createBsonWriter

protected abstract org.bson.AbstractBsonWriter createBsonWriter(OutputStream bsonOutput)
                                                         throws IOException

Throws:

IOException

writeValueToTree

public <T> io.micronaut.json.tree.JsonNode writeValueToTree(io.micronaut.core.type.Argument<T> type,
 T value)
                                                     throws IOException

Specified by:

writeValueToTree in interface io.micronaut.json.JsonMapper

Throws:

IOException

writeValue

public <T> void writeValue(OutputStream outputStream,
 io.micronaut.core.type.Argument<T> type,
 T object)
                    throws IOException

Specified by:

writeValue in interface io.micronaut.json.JsonMapper

Throws:

IOException

writeValueAsBytes

public <T> byte[] writeValueAsBytes(io.micronaut.core.type.Argument<T> type,
 T object)
                             throws IOException

Specified by:

writeValueAsBytes in interface io.micronaut.json.JsonMapper

Throws:

IOException

readValueFromTree

public <T> T readValueFromTree(io.micronaut.json.tree.JsonNode tree,
 io.micronaut.core.type.Argument<T> type)
                        throws IOException

Specified by:

readValueFromTree in interface io.micronaut.json.JsonMapper

Throws:

IOException

readValue

public <T> T readValue(InputStream inputStream,
 io.micronaut.core.type.Argument<T> type)
                throws IOException

Specified by:

readValue in interface io.micronaut.json.JsonMapper

Throws:

IOException

readValue

public <T> T readValue(byte[] byteArray,
 io.micronaut.core.type.Argument<T> type)
                throws IOException

Specified by:

readValue in interface io.micronaut.json.JsonMapper

Throws:

IOException

createReactiveParser

public org.reactivestreams.Processor<byte[],io.micronaut.json.tree.JsonNode> createReactiveParser(Consumer<org.reactivestreams.Processor<byte[],io.micronaut.json.tree.JsonNode>> onSubscribe,
 boolean streamArray)

Specified by:

createReactiveParser in interface io.micronaut.json.JsonMapper

writeValueToTree

public io.micronaut.json.tree.JsonNode writeValueToTree(Object value)
                                                 throws IOException

Specified by:

writeValueToTree in interface io.micronaut.json.JsonMapper

Throws:

IOException

writeValue

public void writeValue(OutputStream outputStream,
 Object object)
                throws IOException

Specified by:

writeValue in interface io.micronaut.json.JsonMapper

Throws:

IOException

writeValueAsBytes

public byte[] writeValueAsBytes(Object object)
                         throws IOException

Specified by:

writeValueAsBytes in interface io.micronaut.json.JsonMapper

Throws:

IOException

getStreamConfig

public io.micronaut.json.JsonStreamConfig getStreamConfig()

Specified by:

getStreamConfig in interface io.micronaut.json.JsonMapper