implements ITCPStreamerContentConsumer
0x00x0080
Members 10
| Offset | Size | Name | Type | Flags | Default |
|---|---|---|---|---|---|
| 0x08 | _length | long | Private | — | |
| 0x08 | _maxBufferSize | long | Private | — | |
| 0x08 | _streamer | TCPStreamer | Private | — | |
| 0x08 | _context | LoggingContext | Private | — | |
| 0x08 | _contentConsumer | ITCPStreamerContentConsumer | Private | — | |
| 0x08 | _segmentsToReadFrom | Queue<Best.HTTP.Shared.PlatformSupport.Memory.BufferSegment> | Private | — | |
| 0x08 | _are | AutoResetEvent | Private | — | |
| 0x08 | _rws | ReaderWriterLockSlim | Private | — | |
| 0x10 | _currentReadSegment | BufferSegment | Private | — | |
| 0x04 | _pullContentInProgress | int | Private | — | |
| 0x007C | 0x04 | unreflected bytes to end of FrameworkTLSByteForwarder | |||
Inherited from Stream 3
| Offset | Size | Name | Type | Flags | Default |
|---|---|---|---|---|---|
| 0x08 | Null | Stream | PublicStatic+1 flags | — | |
| 0x0008 | 0x10 | padding / unreflected | |||
| 0x08 | _activeReadWriteTask | ReadWriteTask | Private+1 flags | — | |
| 0x08 | _asyncActiveSemaphore | SemaphoreSlim | Private+1 flags | — | |
Inherited from MarshalByRefObject 1
| Offset | Size | Name | Type | Flags | Default |
|---|---|---|---|---|---|
| 0x08 | _identity | object | Private+1 flags | — |
Functions 20
| Signature | Flags | Native | Params |
|---|---|---|---|
| bool get_CanRead() | Public+2 flags | — | 0x01 |
| bool get_CanSeek() | Public+2 flags | — | 0x01 |
| bool get_CanWrite() | Public+2 flags | — | 0x01 |
| long get_Length() | Public+2 flags | — | 0x08 |
| long get_Position() | Public+2 flags | — | 0x08 |
| void set_Position(long value) | Public+2 flags | — | 0x08 |
| long get_MaxBufferSize() | PublicFinal+3 flags | — | 0x08 |
| void set_MaxBufferSize(long value) | PublicFinal+3 flags | — | 0x08 |
| void .ctor(TCPStreamer streamer, ITCPStreamerContentConsumer contentConsumer, long maxBufferSize, LoggingContext context) | Public+1 flags | — | 0x08 |
| void Write(const BufferSegment& buffer) | PublicFinal+2 flags | — | 0x10 |
| void PullContentFromStreamer() | Private | — | 0x00 |
| void OnContent(TCPStreamer streamer) | PublicFinal+2 flags | 0x08 | |
| void OnConnectionClosed(TCPStreamer streamer) | PublicFinal+2 flags | 0x08 | |
| void OnError(TCPStreamer streamer, Exception ex) | PublicFinal+2 flags | 0x08 | |
| int Read(const byte[]& buffer, int offset, int count) | Public+1 flags | 0x08 | |
| void Write(const byte[]& buffer, int offset, int count) | Public+1 flags | 0x08 | |
| void Flush() | Public+1 flags | 0x00 | |
| long Seek(long offset, const SeekOrigin& origin) | Public+1 flags | 0x08 | |
| void SetLength(long value) | Public+1 flags | 0x08 | |
| void Dispose(bool disposing) | 2 flags | 0x01 |