TCPStreamer

: Object

Best.HTTP.Shared.PlatformSupport.Network.Tcp.TCPStreamer, com.Tivadar.Best.HTTP 0x0058 (88 B) inherited 0x0010 com.Tivadar.Best.HTTP.dll

implements IDisposable, IHeartbeat

0x00x0058

Members 11

Show inherited members

Offset	Size	Name	Type	Flags	Default
	0x08	_contentConsumer	ITCPStreamerContentConsumer	Private	—
	0x04	MaxBufferedWriteAmount	uint	Public+1 flags	—
0x001C	0x04	padding / unreflected
	0x08	readState	ReadState	Private	—
	0x08	writeState	WriteState	Private	—
	0x08	_socket	Socket	Private	—
	0x08	_loggingContext	LoggingContext	Private	—
	0x01	_disposed	bool	Private	—
0x0041	0x03	padding / unreflected
	0x04	_closed	int	Private	—
	0x04	_isDisconnected	int	Private	—
	0x01	_closeInitiatedByServer	bool	Public	—
0x004D	0x03	padding / unreflected
	0x04	MaxBufferedReadAmount	uint	Private	—
0x0054	0x04	unreflected bytes to end of TCPStreamer

Functions 18

Signature	Flags	Params
ITCPStreamerContentConsumer get_ContentConsumer()	Public+1 flags	0x08
void set_ContentConsumer(ITCPStreamerContentConsumer value)	Public+1 flags	0x08
Socket get_Socket()	Public+1 flags	0x08
LoggingContext get_Context()	Public+1 flags	0x08
bool get_IsConnectionClosed()	Public+1 flags	0x01
int get_MinReceiveBufferSize()	Public+1 flags	0x04
long get_Length()	Public+1 flags	0x08
void .ctor(Socket socket, uint maxReadBufferSize, uint maxWriteBufferSize, LoggingContext _parentLoggingContext)	Public+1 flags	0x08
BufferSegment DequeueReceived()	Public	0x10
void BeginReceive()	Public	0x00
void OnReceived(IAsyncResult asyncResult)	Private	0x08
void EnqueueToSend(const BufferSegment& buffer)	Public	0x10
bool SendFromQueue()	Private	0x01
void OnWroteToNetwork(IAsyncResult ar)	Private	0x08
void Dispose()	PublicFinal+2 flags	0x00
void Best.HTTP.Shared.Extensions.IHeartbeat.OnHeartbeatUpdate(const DateTime& now, const TimeSpan& dif)	PrivateFinal+2 flags	0x08
void Close()	1 flags	0x00
void OnDisconnected(IAsyncResult ar)	Private	0x08

Used by 10

types with a member, parameter or interface of this type

Action`4 Action`4 FrameworkTLSByteForwarder FrameworkTLSStream HTTPOverTCPConnection INegotiationPeer ITCPStreamerContentConsumer Negotiator NonblockingBCTLSStream NonblockingTCPStream

// Best.HTTP.Shared.PlatformSupport.Network.Tcp.TCPStreamer, com.Tivadar.Best.HTTP
// size 0x0058 (88), inherited 0x0010
class TCPStreamer : public Object
{
public:
    ITCPStreamerContentConsumer _contentConsumer;      // 0x0010(0x08) Private
    uint MaxBufferedWriteAmount;                       // 0x0018(0x04) Public InitOnly
    uint8 pad_0[0x04];                             // 0x001C(0x04)
    ReadState readState;                               // 0x0020(0x08) Private
    WriteState writeState;                             // 0x0028(0x08) Private
    Socket _socket;                                    // 0x0030(0x08) Private
    LoggingContext _loggingContext;                    // 0x0038(0x08) Private
    bool _disposed;                                    // 0x0040(0x01) Private
    uint8 pad_1[0x03];                             // 0x0041(0x03)
    int _closed;                                       // 0x0044(0x04) Private
    int _isDisconnected;                               // 0x0048(0x04) Private
    bool _closeInitiatedByServer;                      // 0x004C(0x01) Public
    uint8 pad_2[0x03];                             // 0x004D(0x03)
    uint MaxBufferedReadAmount;                        // 0x0050(0x04) Private
    uint8 pad_3[0x04];                             // 0x0054(0x04)

    ITCPStreamerContentConsumer get_ContentConsumer(); // 0x67a0f0 [Public SpecialName]
    void set_ContentConsumer(ITCPStreamerContentConsumer value); // 0x78b5f0 [Public SpecialName]
    Socket get_Socket(); // 0x617c80 [Public SpecialName]
    LoggingContext get_Context(); // 0x617c20 [Public SpecialName]
    bool get_IsConnectionClosed(); // 0xd2a310 [Public SpecialName]
    int get_MinReceiveBufferSize(); // 0xd2a350 [Public SpecialName]
    long get_Length(); // 0xd2a330 [Public SpecialName]
    void .ctor(Socket socket, uint maxReadBufferSize, uint maxWriteBufferSize, LoggingContext _parentLoggingContext); // 0xd29fe0 [Public SpecialName]
    BufferSegment DequeueReceived(); // 0xd28db0 [Public]
    void BeginReceive(); // 0xd28820 [Public]
    void OnReceived(IAsyncResult asyncResult); // 0xd29520 [Private]
    void EnqueueToSend(BufferSegment buffer); // 0xd28f50 [Public]
    bool SendFromQueue(); // 0xd29e70 [Private]
    void OnWroteToNetwork(IAsyncResult ar); // 0xd299e0 [Private]
    void Dispose(); // 0xd28eb0 [Public Final Virtual NewSlot]
    void Best.HTTP.Shared.Extensions.IHeartbeat.OnHeartbeatUpdate(DateTime now, TimeSpan dif); // 0xd28ad0 [Private Final Virtual NewSlot]
    void Close(); // 0xd28b70 [Assembly]
    void OnDisconnected(IAsyncResult ar); // 0xd291b0 [Private]
};