Package com.azure.storage.blob

Class ProgressReporter

java.lang.Object

com.azure.storage.blob.ProgressReporter

@Deprecated
public final class ProgressReporter
extends Object

Deprecated.

Use ProgressReporter

ProgressReporter offers a convenient way to add progress tracking to a given Flux.

Constructor Summary

Constructors

Constructor	Description
ProgressReporter()	Deprecated.

Method Summary

Modifier and Type	Method	Description
static Flux<ByteBuffer>	addParallelProgressReporting(Flux<ByteBuffer> data, ProgressReceiver progressReceiver, Lock lock, AtomicLong totalProgress)	Deprecated. Use ProgressReporter instead.
static Flux<ByteBuffer>	addProgressReporting(Flux<ByteBuffer> data, ProgressReceiver progressReceiver)	Deprecated. Use ProgressReporter instead.

Methods inherited from class java.lang.Object

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

Constructor Details

ProgressReporter

public ProgressReporter()

Deprecated.

Method Details

addProgressReporting

@Deprecated
public static Flux<ByteBuffer> addProgressReporting(Flux<ByteBuffer> data,
 ProgressReceiver progressReceiver)

Deprecated.

Use ProgressReporter instead.

Adds progress reporting functionality to the given Flux. Each subscription (and therefore each retry) will rewind the progress reported so as not to over-report. The data reported will be the total amount of data emitted so far, or the "current position" of the Flux.

Parameters:

data - The data whose transfer progress is to be tracked.

progressReceiver - ProgressReceiver

Returns:

A Flux that emits the same data as the source but calls a callback to report the total amount of data emitted so far.

addParallelProgressReporting

@Deprecated
public static Flux<ByteBuffer> addParallelProgressReporting(Flux<ByteBuffer> data,
 ProgressReceiver progressReceiver,
 Lock lock,
 AtomicLong totalProgress)

Deprecated.

Use ProgressReporter instead.

Adds parallel progress reporting functionality to the given Flux. Each subscription (and therefore each retry) will rewind the progress reported so as not to over-report. The data reported will be the total amount of data emitted so far, or the "current position" of the Flux in parallel.

Parameters:

data - The data whose transfer progress is to be tracked.

progressReceiver - ProgressReceiver

lock - This lock will be instantiated by the operation initiating the whole transfer to coordinate each ProgressReporterImpl.

totalProgress - We need an AtomicLong to be able to update the value referenced. Because we are already synchronizing with the lock, we don't incur any additional performance hit here by the synchronization.

Returns:

A Flux that emits the same data as the source but calls a callback to report the total amount of data emitted so far.