org.apache.hc.core5.testing.reactive

Class Reactive3TestUtils

java.lang.Object

org.apache.hc.core5.testing.reactive.Reactive3TestUtils

@Internal
public class Reactive3TestUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Reactive3TestUtils.StreamDescription

Constructor Summary

Constructors

Constructor and Description
Reactive3TestUtils()

Method Summary

Modifier and Type	Method and Description
static io.reactivex.rxjava3.core.Single<Reactive3TestUtils.StreamDescription>	consumeStream(org.reactivestreams.Publisher<ByteBuffer> publisher) Consumes the given stream and returns a data structure containing its length and digest.
static String	getStreamHash(long length) Computes the hash of the deterministic stream (as produced by produceStream(long)).
static io.reactivex.rxjava3.core.Flowable<ByteBuffer>	produceStream(long length) Produces a deterministic stream of bytes, in randomly sized chunks of up to 128kB.
static io.reactivex.rxjava3.core.Flowable<ByteBuffer>	produceStream(long length, AtomicReference<String> hash) Produces a deterministic stream of bytes, in randomly sized chunks of up to 128kB, while computing the hash of the random data.
static io.reactivex.rxjava3.core.Flowable<ByteBuffer>	produceStream(long length, int maximumBlockSize, AtomicReference<String> hash) Produces a deterministic stream of bytes, in randomly sized chunks, while computing the hash of the random data.

Methods inherited from class java.lang.Object

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

Constructor Detail

Reactive3TestUtils

public Reactive3TestUtils()

Method Detail

produceStream

public static io.reactivex.rxjava3.core.Flowable<ByteBuffer> produceStream(long length)

Produces a deterministic stream of bytes, in randomly sized chunks of up to 128kB.

Parameters:

length - the number of bytes in the stream

Returns:

a reactive stream of bytes

produceStream

public static io.reactivex.rxjava3.core.Flowable<ByteBuffer> produceStream(long length,
                                                                           AtomicReference<String> hash)

Produces a deterministic stream of bytes, in randomly sized chunks of up to 128kB, while computing the hash of the random data.

Parameters:

length - the number of bytes in the stream

hash - an output argument for the hash, set when the end of the stream is reached; if null, the hash will not be computed

Returns:

a reactive stream of bytes

produceStream

public static io.reactivex.rxjava3.core.Flowable<ByteBuffer> produceStream(long length,
                                                                           int maximumBlockSize,
                                                                           AtomicReference<String> hash)

Produces a deterministic stream of bytes, in randomly sized chunks, while computing the hash of the random data.

Parameters:

length - the number of bytes in the stream

maximumBlockSize - the maximum size of any ByteBuffer in the stream

hash - an output argument for the hash, set when the end of the stream is reached; if null, the hash will not be computed

Returns:

a reactive stream of bytes

getStreamHash

public static String getStreamHash(long length)

Computes the hash of the deterministic stream (as produced by produceStream(long)).

consumeStream

public static io.reactivex.rxjava3.core.Single<Reactive3TestUtils.StreamDescription> consumeStream(org.reactivestreams.Publisher<ByteBuffer> publisher)

Consumes the given stream and returns a data structure containing its length and digest.