Exchange data using Azure IoT Hub device streams

iothub-device-streams-exchange-data.cs

public class DeviceStreams 
{
    ...

    private static async Task HandleIncomingDataAsync(
        NetworkStream localStream, 
        ClientWebSocket remoteStream, 
        CancellationToken cancellationToken)
    {
        var buffer = new byte[10240];

        while (remoteStream.State == WebSocketState.Open)
        {
            var receiveResult = await remoteStream.ReceiveAsync(
                buffer, cancellationToken).ConfigureAwait(false);

            await localStream.WriteAsync(
                buffer, 0, receiveResult.Count).ConfigureAwait(false);
        }
    }

    private static async Task HandleOutgoingDataAsync(
        NetworkStream localStream, 
        ClientWebSocket remoteStream, 
        CancellationToken cancellationToken)
    {
        var buffer = new byte[10240];

        while (localStream.CanRead)
        {
            int receiveCount = await localStream.ReadAsync(
                buffer, 0, buffer.Length).ConfigureAwait(false);

            await remoteStream.SendAsync(
                    new ArraySegment<byte>(buffer, 0, receiveCount), 
                    WebSocketMessageType.Binary,
                    endOfMessage: true, 
                    cancellationToken).ConfigureAwait(false);
        }
    }

    ...
}