@@ -65,7 +65,7 @@ await ValidateServerClientCommunicationAsync(testData, serverConnection, tcpRead
65
65
public async Task Outgoing_TCP_stream_must_be_able_to_write_a_sequence_of_ByteStrings ( )
66
66
{
67
67
var server = await new Server ( this ) . InitializeAsync ( ) ;
68
- var testInput = Enumerable . Range ( 0 , 256 ) . Select ( i => ByteString . FromBytes ( new [ ] { Convert . ToByte ( i ) } ) ) ;
68
+ var testInput = Enumerable . Range ( 0 , 256 ) . Select ( i => ByteString . FromBytes ( new byte [ ] { Convert . ToByte ( i ) } ) ) ;
69
69
var expectedOutput = ByteString . FromBytes ( Enumerable . Range ( 0 , 256 ) . Select ( Convert . ToByte ) . ToArray ( ) ) ;
70
70
71
71
Source . From ( testInput )
@@ -466,7 +466,7 @@ public async Task Outgoing_TCP_stream_must_Echo_should_work_even_if_server_is_in
466
466
. Run ( Materializer ) ;
467
467
468
468
var result = await Source . From ( Enumerable . Repeat ( 0 , 1000 )
469
- . Select ( i => ByteString . FromBytes ( new [ ] { Convert . ToByte ( i ) } ) ) )
469
+ . Select ( i => ByteString . FromBytes ( new byte [ ] { Convert . ToByte ( i ) } ) ) )
470
470
. Via ( Sys . TcpStream ( ) . OutgoingConnection ( serverAddress , halfClose : true ) )
471
471
. RunAggregate ( 0 , ( i , s ) => i + s . Count , Materializer ) . ShouldCompleteWithin ( 10 . Seconds ( ) ) ;
472
472
@@ -573,7 +573,7 @@ public async Task Tcp_listen_stream_must_be_able_to_implement_echo()
573
573
var binding = await bindTask . ShouldCompleteWithin ( 3 . Seconds ( ) ) ;
574
574
575
575
var testInput = Enumerable . Range ( 0 , 255 )
576
- . Select ( i => ByteString . FromBytes ( new [ ] { Convert . ToByte ( i ) } ) )
576
+ . Select ( i => ByteString . FromBytes ( new byte [ ] { Convert . ToByte ( i ) } ) )
577
577
. ToList ( ) ;
578
578
579
579
var expectedOutput = testInput . Aggregate ( ByteString . Empty , ( agg , b ) => agg . Concat ( b ) ) ;
@@ -603,7 +603,7 @@ public async Task Tcp_listen_stream_must_work_with_a_chain_of_echoes()
603
603
var echoConnection = Sys . TcpStream ( ) . OutgoingConnection ( serverAddress ) ;
604
604
605
605
var testInput = Enumerable . Range ( 0 , 255 )
606
- . Select ( i => ByteString . FromBytes ( [ Convert . ToByte ( i ) ] ) )
606
+ . Select ( i => ByteString . FromBytes ( new byte [ ] { Convert . ToByte ( i ) } ) )
607
607
. ToList ( ) ;
608
608
609
609
var expectedOutput = testInput . Aggregate ( ByteString . Empty , ( agg , b ) => agg . Concat ( b ) ) ;
0 commit comments