ReadMessageAsync< TAdapter >()

async ValueTask< byte[]> System.Net.StreamFramer.ReadMessageAsync< TAdapter > ( TAdapter adapter )

inline

Type Constraints

TAdapter

:

IReadWriteAdapter

Definition at line 24 of file StreamFramer.cs.

                                                                                               : IReadWriteAdapter
    {
        if (_eof)
        {
            return null;
        }
        byte[] buffer = _readHeaderBuffer;
        int num;
        for (int offset = 0; offset < buffer.Length; offset += num)
        {
            num = await adapter.ReadAsync(buffer.AsMemory(offset)).ConfigureAwait(continueOnCapturedContext: false);
            if (num == 0)
            {
                if (offset == 0)
                {
                    _eof = true;
                    return null;
                }
                throw new IOException(System.SR.Format(System.SR.net_io_readfailure, System.SR.net_io_connectionclosed));
            }
        }
        _curReadHeader.CopyFrom(buffer, 0);
        if (_curReadHeader.PayloadSize > 65535)
        {
            throw new InvalidOperationException(System.SR.Format(System.SR.net_frame_size, 65535, _curReadHeader.PayloadSize.ToString(NumberFormatInfo.InvariantInfo)));
        }
        buffer = new byte[_curReadHeader.PayloadSize];
        for (int offset = 0; offset < buffer.Length; offset += num)
        {
            num = await adapter.ReadAsync(buffer.AsMemory(offset)).ConfigureAwait(continueOnCapturedContext: false);
            if (num == 0)
            {
                throw new IOException(System.SR.Format(System.SR.net_io_readfailure, System.SR.net_io_connectionclosed));
            }
        }
        return buffer;
    }

References System.Net.StreamFramer._curReadHeader, System.Net.StreamFramer._eof, System.Net.StreamFramer._readHeaderBuffer, System.buffer, System.Net.FrameHeader.CopyFrom(), System.SR.Format(), System.Globalization.NumberFormatInfo.InvariantInfo, System.SR.net_frame_size, System.SR.net_io_connectionclosed, System.SR.net_io_readfailure, System.offset, and System.Net.FrameHeader.PayloadSize.