Package org.forgerock.http.io

Class CharsetDecoderFlowableTransformer

java.lang.Object

org.forgerock.http.io.CharsetDecoderFlowableTransformer

All Implemented Interfaces:

io.reactivex.rxjava3.core.FlowableTransformer<ByteBuffer,CharBuffer>

public final class CharsetDecoderFlowableTransformer
extends Object
implements io.reactivex.rxjava3.core.FlowableTransformer<ByteBuffer,CharBuffer>

A CharsetDecoderFlowableTransformer decodes bytes from a stream of ByteBuffer into a stream of CharBuffer using the given Charset.

Method Summary

Modifier and Type	Method	Description
@NonNull org.reactivestreams.Publisher<CharBuffer>	apply(@NonNull io.reactivex.rxjava3.core.Flowable<ByteBuffer> upstream)
static io.reactivex.rxjava3.core.FlowableTransformer<ByteBuffer,CharBuffer>	decode(Charset charset)	Decodes a flow of ByteBuffer into a flow of CharBuffer using the given Charset.
static io.reactivex.rxjava3.core.FlowableTransformer<ByteBuffer,CharBuffer>	decode(Supplier<CharsetDecoder> decoderSupplier)	Decodes a flow of ByteBuffer into a flow of CharBuffer using the given CharsetDecoder supplier.
static io.reactivex.rxjava3.core.FlowableTransformer<ByteBuffer,CharBuffer>	decode(Supplier<CharsetDecoder> decoderSupplier, int workingByteBufferCapacity, Supplier<CharBuffer> outputBufferSupplier)	Decodes a flow of ByteBuffer into a flow of CharBuffer using the given CharBuffer and CharsetDecoder suppliers.

Methods inherited from class java.lang.Object

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

Method Detail

decode

public static io.reactivex.rxjava3.core.FlowableTransformer<ByteBuffer,CharBuffer> decode(Charset charset)

Decodes a flow of ByteBuffer into a flow of CharBuffer using the given Charset.

This transformer uses a CharsetDecoder configured to replace malformed and unmappable characters in order to behave as closely as possible to the JDK InputStreamReader.

The output char buffers will be new unpooled buffers.

Parameters:

charset - the target decoding charset

Returns:

a flowable transformer of ByteBuffer to CharBuffer

decode

public static io.reactivex.rxjava3.core.FlowableTransformer<ByteBuffer,CharBuffer> decode(Supplier<CharsetDecoder> decoderSupplier)

Decodes a flow of ByteBuffer into a flow of CharBuffer using the given CharsetDecoder supplier.

This transformer uses default's capacity for the working copy and decoded buffers (respectively 8192 and 8192). Decoded buffers are unpooled.

Parameters:

decoderSupplier - a supplier of the charset decoder to use

Returns:

a flowable transformer of ByteBuffer to CharBuffer

decode

public static io.reactivex.rxjava3.core.FlowableTransformer<ByteBuffer,CharBuffer> decode(Supplier<CharsetDecoder> decoderSupplier,
                                                                                                int workingByteBufferCapacity,
                                                                                                Supplier<CharBuffer> outputBufferSupplier)

Decodes a flow of ByteBuffer into a flow of CharBuffer using the given CharBuffer and CharsetDecoder suppliers.

Parameters:

decoderSupplier - a supplier of the charset decoder to use

workingByteBufferCapacity - Size of the working copy ByteBuffer (greater than 32)

outputBufferSupplier - a supplier of the decoded CharBuffer

Returns:

a flowable transformer of ByteBuffer to CharBuffer

apply

@NonNull
public @NonNull org.reactivestreams.Publisher<CharBuffer> apply(@NonNull
                                                                @NonNull io.reactivex.rxjava3.core.Flowable<ByteBuffer> upstream)

Specified by:

apply in interface io.reactivex.rxjava3.core.FlowableTransformer<ByteBuffer,CharBuffer>