Class FitsDataBlockStream

Namespace

FitsModel.FitsStream

Assembly

FitsModel.dll

Reads FitsDataBlocks from a stream and forwards them to any registered DataBlockWriterBase instances.

public class FitsDataBlockStream : Stream, IDisposable, IAsyncDisposable

Inheritance

object

MarshalByRefObject

Stream

FitsDataBlockStream

Implements

IDisposable

IAsyncDisposable

Inherited Members

Stream.Null

Stream.CopyTo(Stream)

Stream.CopyTo(Stream, int)

Stream.CopyToAsync(Stream)

Stream.CopyToAsync(Stream, int)

Stream.CopyToAsync(Stream, CancellationToken)

Stream.CopyToAsync(Stream, int, CancellationToken)

Stream.Dispose()

Stream.Close()

Stream.Dispose(bool)

Stream.DisposeAsync()

Stream.FlushAsync()

Stream.FlushAsync(CancellationToken)

Stream.CreateWaitHandle()

Stream.BeginRead(byte[], int, int, AsyncCallback, object)

Stream.EndRead(IAsyncResult)

Stream.ReadAsync(byte[], int, int)

Stream.ReadAsync(byte[], int, int, CancellationToken)

Stream.ReadAsync(Memory<byte>, CancellationToken)

Stream.ReadExactlyAsync(Memory<byte>, CancellationToken)

Stream.ReadExactlyAsync(byte[], int, int, CancellationToken)

Stream.ReadAtLeastAsync(Memory<byte>, int, bool, CancellationToken)

Stream.BeginWrite(byte[], int, int, AsyncCallback, object)

Stream.EndWrite(IAsyncResult)

Stream.WriteAsync(byte[], int, int)

Stream.WriteAsync(byte[], int, int, CancellationToken)

Stream.WriteAsync(ReadOnlyMemory<byte>, CancellationToken)

Stream.Read(Span<byte>)

Stream.ReadByte()

Stream.ReadExactly(Span<byte>)

Stream.ReadExactly(byte[], int, int)

Stream.ReadAtLeast(Span<byte>, int, bool)

Stream.Write(ReadOnlySpan<byte>)

Stream.WriteByte(byte)

Stream.Synchronized(Stream)

Stream.ObjectInvariant()

Stream.ValidateBufferArguments(byte[], int, int)

Stream.ValidateCopyToArguments(Stream, int)

Stream.CanTimeout

Stream.ReadTimeout

Stream.WriteTimeout

MarshalByRefObject.GetLifetimeService()

MarshalByRefObject.InitializeLifetimeService()

MarshalByRefObject.MemberwiseClone(bool)

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

FitsDataBlockStream(DataBlockWriterBase)

Reads FitsDataBlocks from a stream and forwards them to any registered DataBlockWriterBase instances.

public FitsDataBlockStream(DataBlockWriterBase dataBlockWriter)

Parameters

dataBlockWriter DataBlockWriterBase

Data block writer that will receive data blocks as they are read from the stream.

Properties

CanRead

Not implemented.

public override bool CanRead { get; }

Property Value

bool

CanSeek

Not implemented.

public override bool CanSeek { get; }

Property Value

bool

CanWrite

This stream will continuously accept data and write them to FitsDataBlocks.

public override bool CanWrite { get; }

Property Value

bool

CancelToken

Cancellation token that can be used to flag any streams writing to this stream to stop.

public CancellationToken CancelToken { get; }

Property Value

CancellationToken

DataBlockWriter

Writer that will receive full FitsDataBlocks as they are formed.

public IFitsDataBlockWriter DataBlockWriter { get; }

Property Value

IFitsDataBlockWriter

Length

Not implemented.

public override long Length { get; }

Property Value

long

Position

Not implemented.

public override long Position { get; set; }

Property Value

long

Methods

ChunkMemoryStream(MemoryStream, int)

Splits a MemoryStream into chunks of size n.

public static List<byte[]> ChunkMemoryStream(MemoryStream stream, int n)

Parameters

stream MemoryStream

n int

Returns

List<byte[]>

Flush()

Not implemented.

public override void Flush()

Read(byte[], int, int)

Not implemented.

public override int Read(byte[] buffer, int offset, int count)

Parameters

buffer byte[]

offset int

count int

Returns

int

Seek(long, SeekOrigin)

Not implemented.

public override long Seek(long offset, SeekOrigin origin)

Parameters

offset long

origin SeekOrigin

Returns

long

SetLength(long)

Not implemented.

public override void SetLength(long value)

Parameters

value long

Write(byte[], int, int)

Writes data to this stream. Data is buffered and chunked into 2880-byte FitsDataBlocks. Once a complete block is formed, it is forwarded to all registered DataBlockWriterBase instances.

public override void Write(byte[] buffer, int offset, int count)

Parameters

buffer byte[]

offset int

count int