Search Results for

    Show / Hide Table of Contents

    Class StreamableData<T>

    Represents an instance of PostData that can handle StreamHandler. Allows users full control over how they want to write data to the stream to OpenSearch

    Inheritance
    object
    PostData
    StreamableData<T>
    Implements
    IPostData<T>
    Inherited Members
    PostData.BufferSize
    PostData.NewLineString
    PostData.NewLineByteArray
    PostData.DisableDirectStreaming
    PostData.Type
    PostData.WrittenBytes
    PostData.Empty
    PostData.Serializable<T>(T)
    PostData.MultiJson(IEnumerable<string>)
    PostData.MultiJson(IEnumerable<object>)
    PostData.Bytes(byte[])
    PostData.String(string)
    PostData.StreamHandler<T>(T, Action<T, Stream>, Func<T, Stream, CancellationToken, Task>)
    PostData.BufferIfNeeded(IConnectionConfigurationValues, ref MemoryStream, ref Stream)
    PostData.FinishStream(Stream, MemoryStream, IConnectionConfigurationValues)
    PostData.FinishStreamAsync(Stream, MemoryStream, IConnectionConfigurationValues, CancellationToken)
    object.Equals(object)
    object.Equals(object, object)
    object.GetHashCode()
    object.GetType()
    object.MemberwiseClone()
    object.ReferenceEquals(object, object)
    object.ToString()
    Namespace: OpenSearch.Net
    Assembly: OpenSearch.Net.dll
    Syntax
    public class StreamableData<T> : PostData, IPostData<T>
    Type Parameters
    Name Description
    T

    The data or a state object used during writing, passed to the handlers to avoid boxing

    Constructors

    | Edit this page View Source

    StreamableData(T, Action<T, Stream>, Func<T, Stream, CancellationToken, Task>)

    Declaration
    public StreamableData(T state, Action<T, Stream> syncWriter, Func<T, Stream, CancellationToken, Task> asyncWriter)
    Parameters
    Type Name Description
    T state
    Action<T, Stream> syncWriter
    Func<T, Stream, CancellationToken, Task> asyncWriter

    Methods

    | Edit this page View Source

    Write(Stream, IConnectionConfigurationValues)

    Declaration
    public override void Write(Stream writableStream, IConnectionConfigurationValues settings)
    Parameters
    Type Name Description
    Stream writableStream
    IConnectionConfigurationValues settings
    Overrides
    PostData.Write(Stream, IConnectionConfigurationValues)
    | Edit this page View Source

    WriteAsync(Stream, IConnectionConfigurationValues, CancellationToken)

    Declaration
    public override Task WriteAsync(Stream writableStream, IConnectionConfigurationValues settings, CancellationToken cancellationToken)
    Parameters
    Type Name Description
    Stream writableStream
    IConnectionConfigurationValues settings
    CancellationToken cancellationToken
    Returns
    Type Description
    Task
    Overrides
    PostData.WriteAsync(Stream, IConnectionConfigurationValues, CancellationToken)

    Implements

    IPostData<T>

    Extension Methods

    SuffixExtensions.Suffix(object, string)
    • Edit this page
    • View Source
    In this article
    • Constructors
      • StreamableData(T, Action<T, Stream>, Func<T, Stream, CancellationToken, Task>)
    • Methods
      • Write(Stream, IConnectionConfigurationValues)
      • WriteAsync(Stream, IConnectionConfigurationValues, CancellationToken)
    • Implements
    • Extension Methods
    Back to top Generated by DocFX