Class BlockingSubscribeExtensions

Inheritance

object

BlockingSubscribeExtensions

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 static class BlockingSubscribeExtensions

Methods

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

Declaration

public static ReindexObserver Wait(this IObservable<BulkAllResponse> observable, TimeSpan maximumRunTime, Action<BulkAllResponse> onNext)

Parameters

Type	Name	Description
IObservable<BulkAllResponse>	observable
TimeSpan	maximumRunTime
Action<BulkAllResponse>	onNext

Returns

Type	Description
ReindexObserver

Wait<T>(BulkAllObservable<T>, TimeSpan, Action<BulkAllResponse>)

Declaration

public static BulkAllObserver Wait<T>(this BulkAllObservable<T> observable, TimeSpan maximumRunTime, Action<BulkAllResponse> onNext) where T : class

Parameters

Type	Name	Description
BulkAllObservable<T>	observable
TimeSpan	maximumRunTime
Action<BulkAllResponse>	onNext

Returns

Type	Description
BulkAllObserver

Type Parameters

Name	Description
T

Wait<T>(IObservable<IScrollAllResponse<T>>, TimeSpan, Action<IScrollAllResponse<T>>)

Declaration

public static ScrollAllObserver<T> Wait<T>(this IObservable<IScrollAllResponse<T>> observable, TimeSpan maximumRunTime, Action<IScrollAllResponse<T>> onNext) where T : class

Parameters

Type	Name	Description
IObservable<IScrollAllResponse<T>>	observable
TimeSpan	maximumRunTime
Action<IScrollAllResponse<T>>	onNext

Returns

Type	Description
ScrollAllObserver<T>

Type Parameters

Name	Description
T