Class ScrollAllObservable<T>

Inheritance

object

ScrollAllObservable<T>

Implements

IDisposable

IObservable<ScrollAllResponse<T>>

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 ScrollAllObservable<T> : IDisposable, IObservable<ScrollAllResponse<T>> where T : class

Type Parameters

Name	Description
T

Constructors

ScrollAllObservable(IOpenSearchClient, IScrollAllRequest, CancellationToken)

Declaration

public ScrollAllObservable(IOpenSearchClient client, IScrollAllRequest scrollAllRequest, CancellationToken cancellationToken = default)

Parameters

Type	Name	Description
IOpenSearchClient	client
IScrollAllRequest	scrollAllRequest
CancellationToken	cancellationToken

Properties

IsDisposed

Declaration

public bool IsDisposed { get; }

Property Value

Type	Description
bool

Methods

Dispose()

Declaration

public void Dispose()

Subscribe(IObserver<ScrollAllResponse<T>>)

Declaration

public IDisposable Subscribe(IObserver<ScrollAllResponse<T>> observer)

Parameters

Type	Name	Description
IObserver<ScrollAllResponse<T>>	observer

Returns

Type	Description
IDisposable

Implements

IDisposable

IObservable<T>

Extension Methods

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

SuffixExtensions.Suffix(object, string)