Lines Matching refs:sender

41 // Returns a function that sends data to a provided DataSender |sender|,
43 // resolve to |sender|.
45 return function(sender) {
46 return sender.send(data).then(function(bytesSent) {
48 return sender;
53 // Returns a function that sends data to a provided DataSender |sender|,
55 // bytes sent, and returns a promise that will resolve to |sender|.
57 return function(sender) {
58 return sender.send(data).catch(function(result) {
61 return sender;
66 // Returns a function that cancels sends on the provided DataSender |sender|
67 // with error |cancelReason|, returning a promise that will resolve to |sender|
70 return function(sender) {
71 return sender.cancel(cancelReason).then(function() {
72 return sender;
77 // Checks that attempting to start a send with |sender| fails.
78 function sendAfterClose(sender) {
79 test.assertThrows(sender.send, sender, [], 'DataSender has been closed');
87 return promise.then(function(sender) {
90 return sender;
102 // Serializes and deserializes the provided DataSender |sender|, returning a
104 function serializeRoundTrip(sender) {
106 sender.serialize(),
115 function closeSender(sender) {
116 sender.close();
117 return sender;
122 var sender = createSender();
124 sender.then(sendAndExpectSuccess(generateData(1))),
125 sender.then(sendAndExpectSuccess(generateData(1))),
155 var sender = createSender();
157 sender.then(sendAndExpectError(generateData(2, 'b'), 1, 2)),
158 sender.then(sendAndExpectError(generateData(2, 'b'), 1, 0)),
166 var sender = createSender();
168 sender.then(sendAndExpectSuccess(generateData(2, 'b'))),
169 sender.then(sendAndExpectError(generateData(2, 'b'), 1, 1)),
186 var sender = createSender();
188 sender.then(sendAndExpectError(generateData(5, 'b'), 1, 2)),
189 sender.then(sendAndExpectError(
205 var sender = createSender();
207 sender.then(sendAndExpectError(generateData(1, 'b'), 3, 0)),
208 sender.then(cancelSend(3)),
212 sender.then(function(sender) {
214 sender.cancel, sender, [], 'Cancel already in progress');
215 test.assertThrows(sender.send, sender, [], 'Cancel in progress');
220 var sender = createSender();
222 sender.then(sendAndExpectError(generateData(1, 'b'), FATAL_ERROR, 0)),
223 sender.then(cancelSend(3)),
225 sender
232 var sender = createSender().then(serializeRoundTrip);
234 sender.then(sendAndExpectSuccess(generateData(1))),
235 sender.then(sendAndExpectSuccess(generateData(1))),
252 var sender = createSender().then(serializeRoundTrip);
254 sender.then(sendAndExpectError(generateData(1, 'b'), 4, 0)),
255 sender.then(cancelSend(4)),
262 var sender = createSender();
264 sender.then(sendAndExpectError(generateData(1, 'b'), FATAL_ERROR, 0)),
265 sender.then(sendAndExpectError(generateData(1, 'b'), FATAL_ERROR, 0)),
266 sender.then(serializeRoundTrip),
273 var sender = createSender();
275 sender.then(sendAndExpectError(generateData(1, 'b'), 3, 0)),
276 sender.then(cancelSend(3)),
277 sender.then(serializeRoundTrip),