Class CoordinatedRequestObserverBase<T>

Inheritance

object

CoordinatedRequestObserverBase<T>

BulkAllObserver

ScrollAllObserver<T>

SnapshotObserver

Implements

IObserver<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 abstract class CoordinatedRequestObserverBase<T> : IObserver<T>

Type Parameters

Name	Description
T

Constructors

CoordinatedRequestObserverBase(Action<T>, Action<Exception>, Action)

Declaration

protected CoordinatedRequestObserverBase(Action<T> onNext = null, Action<Exception> onError = null, Action completed = null)

Parameters

Type	Name	Description
Action<T>	onNext
Action<Exception>	onError
Action	completed

Methods

OnCompleted()

Declaration

public void OnCompleted()

OnError(Exception)

Declaration

public void OnError(Exception error)

Parameters

Type	Name	Description
Exception	error

OnNext(T)

Declaration

public void OnNext(T value)

Parameters

Type	Name	Description
T	value

Implements

IObserver<T>

Extension Methods

SuffixExtensions.Suffix(object, string)