/
githubmirror
/
aspnetcore
Обзор
Документация
Войти
/
githubmirror
/
aspnetcore
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
main
src/SignalR/samples/ClientSample/Tcp/SocketReceiver.cs
42 строки
1 KB
Pranav K
Fixup whitespace issues from top-level statement change (#39161)
23 дек 2021, 09:35
Не верифицирован
23 дек 2021, 09:35
c65dac7
Код
Авторство
О чём код?
// Licensed to the .NET Foundation under one or more agreements. // The .NET Foundation licenses this file to you under the MIT license. using System; using System.Collections.Generic; using System.IO.Pipelines; using System.Net.Sockets; using System.Text; namespace ClientSample; public class SocketReceiver { private readonly Socket _socket; private readonly SocketAsyncEventArgs _eventArgs = new SocketAsyncEventArgs(); private readonly SocketAwaitable _awaitable; public SocketReceiver(Socket socket, PipeScheduler scheduler) { _socket = socket; _awaitable = new SocketAwaitable(scheduler); _eventArgs.UserToken = _awaitable; _eventArgs.Completed += (_, e) => ((SocketAwaitable)e.UserToken).Complete(e.BytesTransferred, e.SocketError); } public SocketAwaitable ReceiveAsync(Memory<byte> buffer) { #if NETCOREAPP _eventArgs.SetBuffer(buffer); #else var segment = buffer.GetArray(); _eventArgs.SetBuffer(segment.Array, segment.Offset, segment.Count); #endif if (!_socket.ReceiveAsync(_eventArgs)) { _awaitable.Complete(_eventArgs.BytesTransferred, _eventArgs.SocketError); } return _awaitable; } }