Share via

ProgressReporter Class

Package:
com.azure.storage.blob
Maven Artifact:
com.azure:azure-storage-blob:12.32.0
  • java.lang.Object
    • com.azure.storage.blob.ProgressReporter

@Deprecated
public final class ProgressReporter

Note

This class has been deprecated. Use ProgressReporter

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

Constructor Summary

Constructor Description
ProgressReporter()

Creates a new instance of ProgressReporter.

Method Summary

Modifier and Type Method and Description
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.
static Flux<ByteBuffer> addProgressReporting(Flux<ByteBuffer> data, ProgressReceiver progressReceiver)

Deprecated

Use ProgressReporter instead.

Adds progress reporting functionality to the given Flux.

Methods inherited from java.lang.Object

clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Constructor Details

ProgressReporter

public ProgressReporter()

Creates a new instance of ProgressReporter.

Method Details

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.

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.

Applies to