@@ -133,7 +133,7 @@ private SqlServerInvocation ReadInvocationCore(ref MessagePackReader reader)
133133 var ids = new string [ idCount ] ;
134134 for ( var i = 0 ; i < idCount ; i ++ )
135135 {
136- ids [ i ] = reader . ReadString ( ) ;
136+ ids [ i ] = reader . ReadString ( ) ! ;
137137 }
138138
139139 excludedConnectionIds = ids ;
@@ -152,7 +152,7 @@ public SqlServerTargetedInvocation ReadTargetedInvocation(ReadOnlyMemory<byte> d
152152 ValidateArraySize ( ref reader , 3 , "TargetedInvocation" ) ;
153153
154154 // Read target
155- var target = reader . ReadString ( ) ;
155+ var target = reader . ReadString ( ) ! ;
156156
157157 var invocation = ReadInvocationCore ( ref reader ) ;
158158
@@ -190,7 +190,7 @@ public SqlServerAckMessage ReadAck(ReadOnlyMemory<byte> data)
190190 // See WriteAck for format
191191 reader . ReadByte ( ) ; // Skip header
192192 ValidateArraySize ( ref reader , 2 , "Ack" ) ;
193- return new SqlServerAckMessage ( reader . ReadInt32 ( ) , reader . ReadString ( ) ) ;
193+ return new SqlServerAckMessage ( reader . ReadInt32 ( ) , reader . ReadString ( ) ! ) ;
194194 }
195195
196196
@@ -236,10 +236,10 @@ public SqlServerGroupCommand ReadGroupCommand(ReadOnlyMemory<byte> data)
236236 ValidateArraySize ( ref reader , 5 , "GroupCommand" ) ;
237237
238238 var id = reader . ReadInt32 ( ) ;
239- var serverName = reader . ReadString ( ) ;
239+ var serverName = reader . ReadString ( ) ! ;
240240 var action = ( GroupAction ) reader . ReadByte ( ) ;
241- var groupName = reader . ReadString ( ) ;
242- var connectionId = reader . ReadString ( ) ;
241+ var groupName = reader . ReadString ( ) ! ;
242+ var connectionId = reader . ReadString ( ) ! ;
243243
244244 return new SqlServerGroupCommand ( id , serverName , action , groupName , connectionId ) ;
245245 }
@@ -270,7 +270,7 @@ public static SerializedHubMessage ReadSerializedHubMessage(ref MessagePackReade
270270 var serializations = new SerializedMessage [ count ] ;
271271 for ( var i = 0 ; i < count ; i ++ )
272272 {
273- var protocol = reader . ReadString ( ) ;
273+ var protocol = reader . ReadString ( ) ! ;
274274 var serialized = reader . ReadBytes ( ) ? . ToArray ( ) ?? Array . Empty < byte > ( ) ;
275275
276276 serializations [ i ] = new SerializedMessage ( protocol , serialized ) ;
0 commit comments