Package io.micronaut.http.server.codec

Class TextStreamCodec

java.lang.Object

io.micronaut.http.server.codec.TextStreamCodec

All Implemented Interfaces:

MediaTypeCodec

@Singleton
@Internal
@Requires(bean=ByteBufferFactory.class)
public class TextStreamCodec
extends Object
implements MediaTypeCodec

A MediaTypeCodec that will encode Event objects in order to support Server Sent Events.

Since:

1.0

Author:

Graeme Rocher

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CONFIGURATION_QUALIFIER

Constructor Summary

Constructors

Modifier	Constructor	Description
	TextStreamCodec(ApplicationConfiguration applicationConfiguration, ByteBufferFactory byteBufferFactory, BeanProvider<MediaTypeCodecRegistry> codecRegistryProvider, @Nullable CodecConfiguration codecConfiguration)
protected	TextStreamCodec(Charset defaultCharset, ByteBufferFactory byteBufferFactory, BeanProvider<MediaTypeCodecRegistry> codecRegistryProvider, @Nullable CodecConfiguration codecConfiguration)

Method Summary

Modifier and Type	Method	Description
<T> T	decode(Argument<T> type, InputStream inputStream)	Decode the given type from the given InputStream.
<T> T	decode(Class<T> type, InputStream inputStream)	Decode the given type from the given InputStream.
<T> byte[]	encode(T object)	Encode the given type returning the object as a byte[].
<T, B> ByteBuffer<B>	encode(T object, ByteBufferFactory<?,B> allocator)	Encode the given type returning the object as a ByteBuffer.
<T> void	encode(T object, OutputStream outputStream)	Encode the given type to the given OutputStream.
Collection<MediaType>	getMediaTypes()
protected void	writeAttribute(ByteBuffer eventData, byte[] attribute, String 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.http.codec.MediaTypeCodec

decode, decode, decode, decode, decode, decode, encode, encode, encode, supportsType

Field Details

CONFIGURATION_QUALIFIER

public static final String CONFIGURATION_QUALIFIER

See Also:

• Constant Field Values

Constructor Details

TextStreamCodec

@Inject
public TextStreamCodec(ApplicationConfiguration applicationConfiguration,
 ByteBufferFactory byteBufferFactory,
 BeanProvider<MediaTypeCodecRegistry> codecRegistryProvider,
 @Named("text-stream") @Nullable
 @Nullable CodecConfiguration codecConfiguration)

Parameters:

applicationConfiguration - The application configuration

byteBufferFactory - A byte buffer factory

codecRegistryProvider - A media type codec registry

codecConfiguration - The configuration for the codec

TextStreamCodec

protected TextStreamCodec(Charset defaultCharset,
 ByteBufferFactory byteBufferFactory,
 BeanProvider<MediaTypeCodecRegistry> codecRegistryProvider,
 @Named("text-stream") @Nullable
 @Nullable CodecConfiguration codecConfiguration)

Parameters:

defaultCharset - The default charset

byteBufferFactory - A byte buffer factory

codecRegistryProvider - A media type codec registry

codecConfiguration - The configuration for the codec

Method Details

getMediaTypes

public Collection<MediaType> getMediaTypes()

Specified by:

getMediaTypes in interface MediaTypeCodec

Returns:

The media type of the codec

decode

public <T> T decode(Argument<T> type,
 InputStream inputStream)

Description copied from interface: MediaTypeCodec

Decode the given type from the given InputStream.

Specified by:

decode in interface MediaTypeCodec

Type Parameters:

T - The generic type

Parameters:

type - The type

inputStream - The input stream

Returns:

The decoded result

decode

public <T> T decode(Class<T> type,
 InputStream inputStream)

Description copied from interface: MediaTypeCodec

Decode the given type from the given InputStream.

Specified by:

decode in interface MediaTypeCodec

Type Parameters:

T - The generic type

Parameters:

type - The type

inputStream - The input stream

Returns:

The decoded result

encode

public <T> void encode(T object,
 OutputStream outputStream)

Description copied from interface: MediaTypeCodec

Encode the given type to the given OutputStream.

Specified by:

encode in interface MediaTypeCodec

Type Parameters:

T - The generic type

Parameters:

object - The object to encode

outputStream - The output stream

encode

public <T> byte[] encode(T object)

Description copied from interface: MediaTypeCodec

Encode the given type returning the object as a byte[].

Specified by:

encode in interface MediaTypeCodec

Type Parameters:

T - The generic type

Parameters:

object - The object to encode

Returns:

The decoded result

encode

public <T,
B> ByteBuffer<B> encode(T object,
 ByteBufferFactory<?,B> allocator)

Description copied from interface: MediaTypeCodec

Encode the given type returning the object as a ByteBuffer.

Specified by:

encode in interface MediaTypeCodec

Type Parameters:

T - The generic type

B - The buffer type

Parameters:

object - The object to encode

allocator - The allocator

Returns:

The decoded result

writeAttribute

protected void writeAttribute(ByteBuffer eventData,
 byte[] attribute,
 String value)

Parameters:

eventData - The byte buffer

attribute - The attribute

value - The value