Class ReindexObservable<TSource, TTarget>

Inheritance

object

ReindexObservable<TSource, TTarget>

ReindexObservable<TSource>

Implements

IDisposable

IObservable<BulkAllResponse>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: OpenSearch.Client

Assembly: OpenSearch.Client.dll

Syntax

public class ReindexObservable<TSource, TTarget> : IDisposable, IObservable<BulkAllResponse> where TSource : class where TTarget : class

Type Parameters

Name	Description
TSource
TTarget

Constructors

ReindexObservable(IOpenSearchClient, IConnectionSettingsValues, IReindexRequest<TSource, TTarget>, CancellationToken)

Declaration

public ReindexObservable(IOpenSearchClient client, IConnectionSettingsValues connectionSettings, IReindexRequest<TSource, TTarget> reindexRequest, CancellationToken cancellationToken)

Parameters

Type	Name	Description
IOpenSearchClient	client
IConnectionSettingsValues	connectionSettings
IReindexRequest<TSource, TTarget>	reindexRequest
CancellationToken	cancellationToken

Properties

IsDisposed

Declaration

public bool IsDisposed { get; }

Property Value

Type	Description
bool

Methods

Dispose()

Declaration

public void Dispose()

Subscribe(ReindexObserver)

Declaration

public IDisposable Subscribe(ReindexObserver observer)

Parameters

Type	Name	Description
ReindexObserver	observer

Returns

Type	Description
IDisposable

Subscribe(IObserver<BulkAllResponse>)

Declaration

public IDisposable Subscribe(IObserver<BulkAllResponse> observer)

Parameters

Type	Name	Description
IObserver<BulkAllResponse>	observer

Returns

Type	Description
IDisposable

Implements

IDisposable

IObservable<T>

Extension Methods

BlockingSubscribeExtensions.Wait(IObservable<BulkAllResponse>, TimeSpan, Action<BulkAllResponse>)

SuffixExtensions.Suffix(object, string)