Lines Matching refs:label
7 self.templatedRSEmpty = (label, factory) => {
8 test(() => {}, 'Running templatedRSEmpty with ' + label);
21 }, label + ': instances have the correct methods and properties');
34 }, label + ': calling getReader with invalid arguments should throw appropriate errors');
37 self.templatedRSClosed = (label, factory) => {
38 test(() => {}, 'Running templatedRSClosed with ' + label);
53 }, label + ': cancel() should return a distinct fulfilled promise each time');
60 }, label + ': locked should be false');
67 }, label + ': getReader() should be OK');
81 }, label + ': should be able to acquire multiple readers if they are released in succession');
92 }, label + ': should not be able to acquire a second reader if we don\'t release the first one');
95 self.templatedRSErrored = (label, factory, error) => {
96 test(() => {}, 'Running templatedRSErrored with ' + label);
108 }, label + ': getReader() should return a reader that acts errored');
121 }, label + ': read() twice should give the error each time');
127 }, label + ': locked should be false');
130 self.templatedRSErroredSyncOnly = (label, factory, error) => {
131 test(() => {}, 'Running templatedRSErroredSyncOnly with ' + label);
141 }, label + ': should be able to obtain a second reader, with the correct closed promise');
151 }, label + ': should not be able to obtain additional readers if we don\'t release the first lock');
166 }, label + ': cancel() should return a distinct rejected promise each time');
182 }, label + ': reader cancel() should return a distinct rejected promise each time');
185 self.templatedRSEmptyReader = (label, factory) => {
186 test(() => {}, 'Running templatedRSEmptyReader with ' + label);
199 }, label + ': instances have the correct methods and properties');
207 }, label + ': locked should be true');
220 }, label + ': read() should never settle');
238 }, label + ': two read()s should both never settle');
245 }, label + ': read() should return distinct promises each time');
252 }, label + ': getReader() again on the stream should fail');
274 }, label + ': releasing the lock should reject all pending read requests');
286 }, label + ': releasing the lock should cause further read() calls to reject with a TypeError');
300 }, label + ': releasing the lock should cause closed calls to reject with a TypeError');
311 }, label + ': releasing the lock should cause locked to become false');
322 }, label + ': canceling via the reader should cause the reader to act closed');
329 }, label + ': canceling via the stream should fail');
332 self.templatedRSClosedReader = (label, factory) => {
333 test(() => {}, 'Running templatedRSClosedReader with ' + label);
343 }, label + ': read() should fulfill with { value: undefined, done: true }');
358 }, label + ': read() multiple times should fulfill with { value: undefined, done: true }');
368 }, label + ': read() should work when used within another read() fulfill callback');
376 }, label + ': closed should fulfill with undefined');
393 }, label + ': releasing the lock should cause closed to reject and change identity');
411 }, label + ': cancel() should return a distinct fulfilled promise each time');
414 self.templatedRSErroredReader = (label, factory, error) => {
415 test(() => {}, 'Running templatedRSErroredReader with ' + label);
422 }, label + ': closed should reject with the error');
438 }, label + ': releasing the lock should cause closed to reject and change identity');
445 }, label + ': read() should reject with the error');
448 self.templatedRSTwoChunksOpenReader = (label, factory, chunks) => {
449 test(() => {}, 'Running templatedRSTwoChunksOpenReader with ' + label);
464 }, label + ': calling read() twice without waiting will eventually give both chunks (sequential)');
478 }, label + ': calling read() twice without waiting will eventually give both chunks (nested)');
485 }, label + ': read() should return distinct promises each time');
509 }, label + ': cancel() after a read() should still give that single read result');
512 self.templatedRSTwoChunksClosedReader = function (label, factory, chunks) {
513 test(() => {}, 'Running templatedRSTwoChunksClosedReader with ' + label);
531 }, label + ': third read(), without waiting, should give { value: undefined, done: true } (sequential)');
549 }, label + ': third read(), without waiting, should give { value: undefined, done: true } (nested)');
569 }, label +
589 }, label + ': releasing the lock after the stream is closed should cause locked to become false');
603 }, label + ': releasing the lock should cause further read() calls to reject with a TypeError');
630 }, label + ': reader\'s closed property always returns the same promise');
633 self.templatedRSTeeCancel = (label, factory) => {
634 test(() => {}, `Running templatedRSTeeCancel with ${label}`);
658 }, `${label}: canceling both branches should aggregate the cancel reasons into an array`);
682 }, `${label}: canceling both branches in reverse order should aggregate the cancel reasons into an array`);
699 }, `${label}: failing to cancel the original stream should cause cancel() to reject on branches`);
719 }, `${label}: erroring a teed stream should properly handle canceled branches`);