|
1 |
| -import { expect } from 'chai'; |
| 1 | +import { assert, expect } from 'chai'; |
2 | 2 | import { describe, it } from 'mocha';
|
3 | 3 |
|
4 | 4 | import { expectJSON } from '../../__testUtils__/expectJSON';
|
5 | 5 | import { resolveOnNextTick } from '../../__testUtils__/resolveOnNextTick';
|
6 | 6 |
|
7 |
| -import { invariant } from '../../jsutils/invariant'; |
8 | 7 | import { isAsyncIterable } from '../../jsutils/isAsyncIterable';
|
9 | 8 |
|
10 | 9 | import { parse } from '../../language/parser';
|
@@ -176,7 +175,7 @@ describe('Subscription Initialization Phase', () => {
|
176 | 175 | document: parse('subscription { foo }'),
|
177 | 176 | rootValue: { foo: fooGenerator },
|
178 | 177 | });
|
179 |
| - invariant(isAsyncIterable(subscription)); |
| 178 | + assert(isAsyncIterable(subscription)); |
180 | 179 |
|
181 | 180 | expect(await subscription.next()).to.deep.equal({
|
182 | 181 | done: false,
|
@@ -211,7 +210,7 @@ describe('Subscription Initialization Phase', () => {
|
211 | 210 | schema,
|
212 | 211 | document: parse('subscription { foo }'),
|
213 | 212 | });
|
214 |
| - invariant(isAsyncIterable(subscription)); |
| 213 | + assert(isAsyncIterable(subscription)); |
215 | 214 |
|
216 | 215 | expect(await subscription.next()).to.deep.equal({
|
217 | 216 | done: false,
|
@@ -249,7 +248,7 @@ describe('Subscription Initialization Phase', () => {
|
249 | 248 | schema,
|
250 | 249 | document: parse('subscription { foo }'),
|
251 | 250 | });
|
252 |
| - invariant(isAsyncIterable(subscription)); |
| 251 | + assert(isAsyncIterable(subscription)); |
253 | 252 |
|
254 | 253 | expect(await subscription.next()).to.deep.equal({
|
255 | 254 | done: false,
|
@@ -283,7 +282,7 @@ describe('Subscription Initialization Phase', () => {
|
283 | 282 | rootValue: { customFoo: fooGenerator },
|
284 | 283 | subscribeFieldResolver: (root) => root.customFoo(),
|
285 | 284 | });
|
286 |
| - invariant(isAsyncIterable(subscription)); |
| 285 | + assert(isAsyncIterable(subscription)); |
287 | 286 |
|
288 | 287 | expect(await subscription.next()).to.deep.equal({
|
289 | 288 | done: false,
|
@@ -331,7 +330,7 @@ describe('Subscription Initialization Phase', () => {
|
331 | 330 | schema,
|
332 | 331 | document: parse('subscription { foo bar }'),
|
333 | 332 | });
|
334 |
| - invariant(isAsyncIterable(subscription)); |
| 333 | + assert(isAsyncIterable(subscription)); |
335 | 334 |
|
336 | 335 | expect(didResolveFoo).to.equal(true);
|
337 | 336 | expect(didResolveBar).to.equal(false);
|
@@ -547,10 +546,10 @@ describe('Subscription Publish Phase', () => {
|
547 | 546 | const pubsub = new SimplePubSub<Email>();
|
548 | 547 |
|
549 | 548 | const subscription = await createSubscription(pubsub);
|
550 |
| - invariant(isAsyncIterable(subscription)); |
| 549 | + assert(isAsyncIterable(subscription)); |
551 | 550 |
|
552 | 551 | const secondSubscription = await createSubscription(pubsub);
|
553 |
| - invariant(isAsyncIterable(secondSubscription)); |
| 552 | + assert(isAsyncIterable(secondSubscription)); |
554 | 553 |
|
555 | 554 | const payload1 = subscription.next();
|
556 | 555 | const payload2 = secondSubscription.next();
|
@@ -589,7 +588,7 @@ describe('Subscription Publish Phase', () => {
|
589 | 588 | it('produces a payload per subscription event', async () => {
|
590 | 589 | const pubsub = new SimplePubSub<Email>();
|
591 | 590 | const subscription = await createSubscription(pubsub);
|
592 |
| - invariant(isAsyncIterable(subscription)); |
| 591 | + assert(isAsyncIterable(subscription)); |
593 | 592 |
|
594 | 593 | // Wait for the next subscription payload.
|
595 | 594 | const payload = subscription.next();
|
@@ -678,7 +677,7 @@ describe('Subscription Publish Phase', () => {
|
678 | 677 | it('produces a payload when there are multiple events', async () => {
|
679 | 678 | const pubsub = new SimplePubSub<Email>();
|
680 | 679 | const subscription = await createSubscription(pubsub);
|
681 |
| - invariant(isAsyncIterable(subscription)); |
| 680 | + assert(isAsyncIterable(subscription)); |
682 | 681 |
|
683 | 682 | let payload = subscription.next();
|
684 | 683 |
|
@@ -744,7 +743,7 @@ describe('Subscription Publish Phase', () => {
|
744 | 743 | it('should not trigger when subscription is already done', async () => {
|
745 | 744 | const pubsub = new SimplePubSub<Email>();
|
746 | 745 | const subscription = await createSubscription(pubsub);
|
747 |
| - invariant(isAsyncIterable(subscription)); |
| 746 | + assert(isAsyncIterable(subscription)); |
748 | 747 |
|
749 | 748 | let payload = subscription.next();
|
750 | 749 |
|
@@ -798,7 +797,7 @@ describe('Subscription Publish Phase', () => {
|
798 | 797 | it('should not trigger when subscription is thrown', async () => {
|
799 | 798 | const pubsub = new SimplePubSub<Email>();
|
800 | 799 | const subscription = await createSubscription(pubsub);
|
801 |
| - invariant(isAsyncIterable(subscription)); |
| 800 | + assert(isAsyncIterable(subscription)); |
802 | 801 |
|
803 | 802 | let payload = subscription.next();
|
804 | 803 |
|
@@ -851,7 +850,7 @@ describe('Subscription Publish Phase', () => {
|
851 | 850 | it('event order is correct for multiple publishes', async () => {
|
852 | 851 | const pubsub = new SimplePubSub<Email>();
|
853 | 852 | const subscription = await createSubscription(pubsub);
|
854 |
| - invariant(isAsyncIterable(subscription)); |
| 853 | + assert(isAsyncIterable(subscription)); |
855 | 854 |
|
856 | 855 | let payload = subscription.next();
|
857 | 856 |
|
@@ -942,7 +941,7 @@ describe('Subscription Publish Phase', () => {
|
942 | 941 |
|
943 | 942 | const document = parse('subscription { newMessage }');
|
944 | 943 | const subscription = await subscribe({ schema, document });
|
945 |
| - invariant(isAsyncIterable(subscription)); |
| 944 | + assert(isAsyncIterable(subscription)); |
946 | 945 |
|
947 | 946 | expect(await subscription.next()).to.deep.equal({
|
948 | 947 | done: false,
|
@@ -1003,7 +1002,7 @@ describe('Subscription Publish Phase', () => {
|
1003 | 1002 |
|
1004 | 1003 | const document = parse('subscription { newMessage }');
|
1005 | 1004 | const subscription = await subscribe({ schema, document });
|
1006 |
| - invariant(isAsyncIterable(subscription)); |
| 1005 | + assert(isAsyncIterable(subscription)); |
1007 | 1006 |
|
1008 | 1007 | expect(await subscription.next()).to.deep.equal({
|
1009 | 1008 | done: false,
|
|
0 commit comments