Lines Matching refs:protocol
60 var protocol = tuple.Item2; in WriteReadMessage_Test()
62 await protocol.WriteMessageBeginAsync(expected, default); in WriteReadMessage_Test()
63 await protocol.WriteMessageEndAsync(default); in WriteReadMessage_Test()
67 var actualMessage = await protocol.ReadMessageBeginAsync(default); in WriteReadMessage_Test()
68 await protocol.ReadMessageEndAsync(default); in WriteReadMessage_Test()
94 var protocol = tuple.Item2; in WriteReadStruct_Test()
96 await protocol.WriteStructBeginAsync(expected, default); in WriteReadStruct_Test()
97 await protocol.WriteStructEndAsync(default); in WriteReadStruct_Test()
101 var actual = await protocol.ReadStructBeginAsync(default); in WriteReadStruct_Test()
102 await protocol.ReadStructEndAsync(default); in WriteReadStruct_Test()
129 var protocol = tuple.Item2; in WriteReadField_Test()
131 await protocol.WriteFieldBeginAsync(expected, default); in WriteReadField_Test()
132 await protocol.WriteFieldEndAsync(default); in WriteReadField_Test()
136 var actual = await protocol.ReadFieldBeginAsync(default); in WriteReadField_Test()
137 await protocol.ReadFieldEndAsync(default); in WriteReadField_Test()
162 var protocol = tuple.Item2; in WriteReadMap_Test()
164 await protocol.WriteMapBeginAsync(expected, default); in WriteReadMap_Test()
165 await protocol.WriteMapEndAsync(default); in WriteReadMap_Test()
169 var actual = await protocol.ReadMapBeginAsync(default); in WriteReadMap_Test()
170 await protocol.ReadMapEndAsync(default); in WriteReadMap_Test()
196 var protocol = tuple.Item2; in WriteReadList_Test()
198 await protocol.WriteListBeginAsync(expected, default); in WriteReadList_Test()
199 await protocol.WriteListEndAsync(default); in WriteReadList_Test()
203 var actual = await protocol.ReadListBeginAsync(default); in WriteReadList_Test()
204 await protocol.ReadListEndAsync(default); in WriteReadList_Test()
229 var protocol = tuple.Item2; in WriteReadSet_Test()
231 await protocol.WriteSetBeginAsync(expected, default); in WriteReadSet_Test()
232 await protocol.WriteSetEndAsync(default); in WriteReadSet_Test()
236 var actual = await protocol.ReadSetBeginAsync(default); in WriteReadSet_Test()
237 await protocol.ReadSetEndAsync(default); in WriteReadSet_Test()
262 var protocol = tuple.Item2; in WriteReadBool_Test()
264 await protocol.WriteBoolAsync(expected, default); in WriteReadBool_Test()
268 var actual = await protocol.ReadBoolAsync(default); in WriteReadBool_Test()
293 var protocol = tuple.Item2; in WriteReadByte_Test()
295 await protocol.WriteByteAsync(expected, default); in WriteReadByte_Test()
299 var actual = await protocol.ReadByteAsync(default); in WriteReadByte_Test()
324 var protocol = tuple.Item2; in WriteReadI16_Test()
326 await protocol.WriteI16Async(expected, default); in WriteReadI16_Test()
330 var actual = await protocol.ReadI16Async(default); in WriteReadI16_Test()
355 var protocol = tuple.Item2; in WriteReadI32_Test()
357 await protocol.WriteI32Async(expected, default); in WriteReadI32_Test()
361 var actual = await protocol.ReadI32Async(default); in WriteReadI32_Test()
386 var protocol = tuple.Item2; in WriteReadI64_Test()
388 await protocol.WriteI64Async(expected, default); in WriteReadI64_Test()
392 var actual = await protocol.ReadI64Async(default); in WriteReadI64_Test()
417 var protocol = tuple.Item2; in WriteReadDouble_Test()
419 await protocol.WriteDoubleAsync(expected, default); in WriteReadDouble_Test()
423 var actual = await protocol.ReadDoubleAsync(default); in WriteReadDouble_Test()
448 var protocol = tuple.Item2; in WriteReadString_Test()
450 await protocol.WriteStringAsync(expected, default); in WriteReadString_Test()
454 var actual = await protocol.ReadStringAsync(default); in WriteReadString_Test()
479 var protocol = tuple.Item2; in WriteReadBinary_Test()
481 await protocol.WriteBinaryAsync(expected, default); in WriteReadBinary_Test()
485 var actual = await protocol.ReadBinaryAsync(default); in WriteReadBinary_Test()
501 if( Activator.CreateInstance(protocolType, streamClientTransport) is TProtocol protocol) in GetProtocolInstance()
502 return new Tuple<Stream, TProtocol>(memoryStream, protocol); in GetProtocolInstance()