Class ChunkedEncodedPublisher

java.lang.Object

software.amazon.awssdk.http.auth.aws.internal.signer.chunkedencoding.ChunkedEncodedPublisher

All Implemented Interfaces:

org.reactivestreams.Publisher<ByteBuffer>

public class ChunkedEncodedPublisher
extends Object
implements org.reactivestreams.Publisher<ByteBuffer>

An implementation of chunk-transfer encoding, but by wrapping a Publisher of ByteBuffer. This implementation supports chunk-headers, chunk-extensions.

Per RFC-7230, a chunk-transfer encoded message is defined as:

     chunked-body   = *chunk
                      last-chunk
                      trailer-part
                      CRLF
     chunk          = chunk-size [ chunk-ext ] CRLF
                      chunk-data CRLF
     chunk-size     = 1*HEXDIG
     last-chunk     = 1*("0") [ chunk-ext ] CRLF
     chunk-data     = 1*OCTET ; a sequence of chunk-size octets

     chunk-ext      = *( ";" chunk-ext-name [ "=" chunk-ext-val ] )
     chunk-ext-name = token
     chunk-ext-val  = token / quoted-string

     trailer-part   = *( header-field CRLF )
 

See Also:

• ChunkedEncodedInputStream

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ChunkedEncodedPublisher.Builder

Constructor Summary

Constructors

Constructor	Description
ChunkedEncodedPublisher(ChunkedEncodedPublisher.Builder b)

Method Summary

Modifier and Type	Method	Description
org.reactivestreams.Publisher<Iterable<ByteBuffer>>	addTrailingChunks(org.reactivestreams.Publisher<Iterable<ByteBuffer>> upstream)
static ChunkedEncodedPublisher.Builder	builder()
org.reactivestreams.Publisher<ByteBuffer>	map(org.reactivestreams.Publisher<ByteBuffer> upstream, Function<? super ByteBuffer,? extends ByteBuffer> mapper)
void	subscribe(org.reactivestreams.Subscriber<? super ByteBuffer> subscriber)

Methods inherited from class java.lang.Object

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

Constructor Details

ChunkedEncodedPublisher

public ChunkedEncodedPublisher(ChunkedEncodedPublisher.Builder b)

Method Details

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super ByteBuffer> subscriber)

Specified by:

subscribe in interface org.reactivestreams.Publisher<ByteBuffer>

builder

public static ChunkedEncodedPublisher.Builder builder()

addTrailingChunks

public org.reactivestreams.Publisher<Iterable<ByteBuffer>> addTrailingChunks(org.reactivestreams.Publisher<Iterable<ByteBuffer>> upstream)

map

public org.reactivestreams.Publisher<ByteBuffer> map(org.reactivestreams.Publisher<ByteBuffer> upstream,
 Function<? super ByteBuffer,? extends ByteBuffer> mapper)