Lines Matching refs:protocol

30   TProtocol protocol;
35         return Primitive(protocol.readBool, protocol.writeBool, false);
38         return Primitive(protocol.readByte, protocol.writeByte, 0);
41         return Primitive(protocol.readI16, protocol.writeI16, 0);
44         return Primitive(protocol.readI32, protocol.writeI32, 0);
47         return Primitive(protocol.readI64, protocol.writeI64, 0);
50         return Primitive(protocol.readDouble, protocol.writeDouble, 0);
53         return Primitive(protocol.readString, protocol.writeString, '');
62     protocol.writeMessageEnd();
64     await protocol.transport.flush();
66     protocol.readMessageBegin();
74     protocol.writeMessageEnd();
76     await protocol.transport.flush();
78     protocol.readMessageBegin();
86       protocol.writeMessageEnd();
88       await protocol.transport.flush();
90       var subject = protocol.readMessageBegin();
100       protocol.writeStructBegin(input);
101       protocol.writeStructEnd();
102       protocol.writeMessageEnd();
104       await protocol.transport.flush();
106       protocol.readMessageBegin();
107       var output = protocol.readStructBegin();
116       protocol.writeFieldBegin(input);
117       protocol.writeFieldEnd();
118       protocol.writeMessageEnd();
120       await protocol.transport.flush();
122       protocol.readMessageBegin();
123       var output = protocol.readFieldBegin();
133       protocol.writeMapBegin(input);
134       protocol.writeMapEnd();
135       protocol.writeMessageEnd();
137       await protocol.transport.flush();
139       protocol.readMessageBegin();
140       var output = protocol.readMapBegin();
150       protocol.writeListBegin(input);
151       protocol.writeListEnd();
152       protocol.writeMessageEnd();
154       await protocol.transport.flush();
156       protocol.readMessageBegin();
157       var output = protocol.readListBegin();
166       protocol.writeSetBegin(input);
167       protocol.writeSetEnd();
168       protocol.writeMessageEnd();
170       await protocol.transport.flush();
172       protocol.readMessageBegin();
173       var output = protocol.readListBegin();
240       protocol.writeBinary(input);
241       protocol.writeMessageEnd();
243       await protocol.transport.flush();
245       protocol.readMessageBegin();
246       var output = protocol.readBinary();
254       protocol.writeStructBegin(TStruct());
255       protocol.writeFieldBegin(TField('success', TType.MAP, 0));
256       protocol.writeMapBegin(TMap(TType.I32, TType.MAP, 2));
258       protocol.writeI32(1); // key
259       protocol.writeMapBegin(TMap(TType.I32, TType.I32, 1));
260       protocol.writeI32(10); // key
261       protocol.writeI32(20); // value
262       protocol.writeMapEnd();
264       protocol.writeI32(2); // key
265       protocol.writeMapBegin(TMap(TType.I32, TType.I32, 1));
266       protocol.writeI32(30); // key
267       protocol.writeI32(40); // value
268       protocol.writeMapEnd();
270       protocol.writeMapEnd();
271       protocol.writeFieldEnd();
272       protocol.writeFieldStop();
273       protocol.writeStructEnd();
274       protocol.writeMessageEnd();
276       await protocol.transport.flush();
278       protocol.readMessageBegin();
279       protocol.readStructBegin();
280       expect(protocol.readFieldBegin().type, TType.MAP);
281       expect(protocol.readMapBegin().length, 2);
283       expect(protocol.readI32(), 1); // key
284       expect(protocol.readMapBegin().length, 1);
285       expect(protocol.readI32(), 10); // key
286       expect(protocol.readI32(), 20); // value
287       protocol.readMapEnd();
289       expect(protocol.readI32(), 2); // key
290       expect(protocol.readMapBegin().length, 1);
291       expect(protocol.readI32(), 30); // key
292       expect(protocol.readI32(), 40); // value
293       protocol.readMapEnd();
295       protocol.readMapEnd();
296       protocol.readFieldEnd();
297       protocol.readStructEnd();
298       protocol.readMessageEnd();
303       protocol.writeMapBegin(TMap(TType.I32, TType.LIST, 2));
305       protocol.writeI32(1); // key
306       protocol.writeListBegin(TList(TType.MAP, 1));
307       protocol.writeMapBegin(TMap(TType.I32, TType.I32, 1));
308       protocol.writeI32(10); // key
309       protocol.writeI32(20); // value
310       protocol.writeMapEnd();
311       protocol.writeListEnd();
313       protocol.writeI32(2); // key
314       protocol.writeListBegin(TList(TType.MAP, 1));
315       protocol.writeMapBegin(TMap(TType.I32, TType.I32, 1));
316       protocol.writeI32(30); // key
317       protocol.writeI32(40); // value
318       protocol.writeMapEnd();
319       protocol.writeListEnd();
321       protocol.writeMapEnd();
322       protocol.writeMessageEnd();
324       await protocol.transport.flush();
326       protocol.readMessageBegin();
327       expect(protocol.readMapBegin().length, 2);
329       expect(protocol.readI32(), 1); // key
330       expect(protocol.readListBegin().length, 1);
331       expect(protocol.readMapBegin().length, 1);
332       expect(protocol.readI32(), 10); // key
333       expect(protocol.readI32(), 20); // value
334       protocol.readMapEnd();
335       protocol.readListEnd();
337       expect(protocol.readI32(), 2); // key
338       expect(protocol.readListBegin().length, 1);
339       expect(protocol.readMapBegin().length, 1);
340       expect(protocol.readI32(), 30); // key
341       expect(protocol.readI32(), 40); // value
342       protocol.readMapEnd();
343       protocol.readListEnd();
345       protocol.readMapEnd();
346       protocol.readMessageEnd();
352       protocol = TJsonProtocol(TBufferedTransport());
353       protocol.writeMessageBegin(message);
369       var protocol = TJsonProtocol(transport);
371       await protocol.transport.flush();
373       var subject = protocol.readString();
383       protocol = TBinaryProtocol(TBufferedTransport());
384       protocol.writeMessageBegin(message);
392       protocol = TCompactProtocol(TBufferedTransport());
393       protocol.writeMessageBegin(message);