@@ -387,28 +387,6 @@ describe('{{ api.naming.version }}.{{ service.name }}Client', () => {
387
387
{{- util .verifyUUID (method ) }}
388
388
});
389
389
390
- it('invokes {{ method .name .toCamelCase () }} without error and gaxServerStreamingRetries enabled', async () => {
391
- const client = new {{ service .name .toLowerCase () }} Module.{{ api .naming .version }} .{{ service .name }} Client({gaxServerStreamingRetries: true});
392
- {%- if method .options and method .options .deprecated %}
393
- const stub = sinon.stub(client, 'warn');
394
- {%- endif %}
395
- client.{{ id .get (" initialize" ) }} ();
396
- {{ util .initRequestWithHeaderParam (method ) -}}
397
- {{ util .initResponse (method ) }}
398
- client.innerApiCalls.{{ method .name .toCamelCase (true ) }} = stubSimpleCall(expectedResponse);
399
- const [response] = await client.{{ method .name .toCamelCase () }} (request);
400
- {%- if method .options and method .options .deprecated %}
401
- assert(stub.calledOnce);
402
- {%- endif %}
403
- {%- if method .isDiregapicLRO %}
404
- assert.deepStrictEqual(response.latestResponse, expectedResponse);
405
- {%- else %}
406
- assert.deepStrictEqual(response, expectedResponse);
407
- {%- endif %}
408
- {{- util .verifyHeaderRequestParams (method ) }}
409
- {{- util .verifyUUID (method ) }}
410
- });
411
-
412
390
it('invokes {{ method .name .toCamelCase () }} without error using callback', async () => {
413
391
const client = new {{ service .name .toLowerCase () }} Module.{{ api .naming .version }} .{{ service .name }} Client(
414
392
{{- util .initClientOptions (api .rest ) -}}
@@ -636,6 +614,32 @@ describe('{{ api.naming.version }}.{{ service.name }}Client', () => {
636
614
{{- util .verifyHeaderRequestParams (method ) }}
637
615
});
638
616
617
+ it('invokes {{ method .name .toCamelCase () }} without error and gaxServerStreamingRetries enabled', async () => {
618
+ const client = new {{ service .name .toLowerCase () }} Module.{{ api .naming .version }} .{{ service .name }} Client({gaxServerStreamingRetries: true});
619
+ {%- if method .options and method .options .deprecated %}
620
+ const stub = sinon.stub(client, 'warn');
621
+ {%- endif %}
622
+ client.{{ id .get (" initialize" ) }} ();
623
+ {{ util .initRequestWithHeaderParam (method ) -}}
624
+ {{ util .initResponse (method ) }}
625
+ client.innerApiCalls.{{ method .name .toCamelCase (true ) }} = stubServerStreamingCall(expectedResponse);
626
+ const stream = client.{{ method .name .toCamelCase () }} (request);
627
+ const promise = new Promise((resolve, reject) => {
628
+ stream.on('data', (response: protos{{ method .outputInterface }} ) => {
629
+ resolve(response);
630
+ });
631
+ stream.on('error', (err: Error) => {
632
+ reject(err);
633
+ });
634
+ });
635
+ const response = await promise;
636
+ {%- if method .options and method .options .deprecated %}
637
+ assert(stub.calledOnce);
638
+ {%- endif %}
639
+ assert.deepStrictEqual(response, expectedResponse);
640
+ {{- util .verifyHeaderRequestParams (method ) }}
641
+ });
642
+
639
643
it('invokes {{ method .name .toCamelCase () }} with error', async () => {
640
644
const client = new {{ service .name .toLowerCase () }} Module.{{ api .naming .version }} .{{ service .name }} Client({{- util .initClientOptions (api .rest ) -}} );
641
645
{%- if method .options and method .options .deprecated %}
0 commit comments