com.artipie.asto.rx

Class RxCopy

java.lang.Object

com.artipie.asto.rx.RxCopy

public class RxCopy
extends Object

A reactive version of Copy.

Since:

0.19

Constructor Summary

Constructors

Constructor and Description
RxCopy(RxStorage from, List<Key> keys) Ctor.
RxCopy(RxStorage from, List<Key> keys, Integer parallelism) Ctor.

Method Summary

Modifier and Type	Method and Description
io.reactivex.Completable	copy(RxStorage to) Copy key to storage.

Methods inherited from class java.lang.Object

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

Constructor Detail

RxCopy

public RxCopy(RxStorage from,
              List<Key> keys)

Ctor.

Parameters:

from - The storage to copy from.

keys - The keys to copy.

RxCopy

public RxCopy(RxStorage from,
              List<Key> keys,
              Integer parallelism)

Ctor.

Parameters:

from - The storage to copy from.

keys - The keys to copy.

parallelism - The parallelism level.

Method Detail

copy

public io.reactivex.Completable copy(RxStorage to)

Copy key to storage.

Parameters:

to - The storage to copy to.

Returns:

The completion signal.