Class BulkAllObservable<T>

Inheritance

object

BulkAllObservable<T>

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 BulkAllObservable<T> : IDisposable, IObservable<BulkAllResponse> where T : class

Type Parameters

Name	Description
T

Constructors

BulkAllObservable(IOpenSearchClient, IBulkAllRequest<T>, CancellationToken)

Declaration

public BulkAllObservable(IOpenSearchClient client, IBulkAllRequest<T> partitionedBulkRequest, CancellationToken cancellationToken = default)

Parameters

Type	Name	Description
IOpenSearchClient	client
IBulkAllRequest<T>	partitionedBulkRequest
CancellationToken	cancellationToken

Methods

Dispose()

Declaration

public void Dispose()

Subscribe(BulkAllObserver)

Declaration

public IDisposable Subscribe(BulkAllObserver observer)

Parameters

Type	Name	Description
BulkAllObserver	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<T>(BulkAllObservable<T>, TimeSpan, Action<BulkAllResponse>)

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

SuffixExtensions.Suffix(object, string)