Class ReindexObservable<TSource>

Inheritance

object

ReindexObservable<TSource, TSource>

ReindexObservable<TSource>

Implements

IDisposable

IObservable<BulkAllResponse>

Inherited Members

ReindexObservable<TSource, TSource>.IsDisposed

ReindexObservable<TSource, TSource>.Dispose()

ReindexObservable<TSource, TSource>.Subscribe(IObserver<BulkAllResponse>)

ReindexObservable<TSource, TSource>.Subscribe(ReindexObserver)

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> : ReindexObservable<TSource, TSource>, IDisposable, IObservable<BulkAllResponse> where TSource : class

Type Parameters

Name	Description
TSource

Constructors

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

Declaration

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

Parameters

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

Implements

IDisposable

IObservable<T>

Extension Methods

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

SuffixExtensions.Suffix(object, string)