Use ember-concurrency v2 decorator syntax

app/components/email-input.js

@@ -12,7 +12,7 @@ export default class EmailInput extends Component {
   @tracked isEditing = false;
   @tracked disableResend = false;
 
-  @task(function* () {
+  @task *resendEmailTask() {
     try {
       yield this.args.user.resendVerificationEmail();
       this.disableResend = true;
@@ -23,16 +23,15 @@ export default class EmailInput extends Component {
         this.notifications.error('Unknown error in resending message');
       }
     }
-  })
-  resendEmailTask;
+  }
 
   @action
   editEmail() {
     this.value = this.args.user.email;
     this.isEditing = true;
   }
 
-  @task(function* () {
+  @task *saveEmailTask() {
     let userEmail = this.value;
     let user = this.args.user;
 
@@ -49,6 +48,5 @@ export default class EmailInput extends Component {
 
       this.notifications.error(`Error in saving email: ${msg}`);
     }
-  })
-  saveEmailTask;
+  }
 }

app/components/follow-button.js

@@ -29,7 +29,7 @@ export default class extends Component {
   }).drop())
   followStateTask;
 
-  @task(function* () {
+  @task *toggleFollowTask() {
     let crate = this.args.crate;
 
     try {
@@ -42,6 +42,5 @@ export default class extends Component {
         } crate. Please try again later!`,
       );
     }
-  })
-  toggleFollowTask;
+  }
 }

app/components/pending-owner-invite-row.js

@@ -10,7 +10,7 @@ export default class PendingOwnerInviteRow extends Component {
   @tracked isAccepted = false;
   @tracked isDeclined = false;
 
-  @task(function* () {
+  @task *acceptInvitationTask() {
     this.args.invite.set('accepted', true);
 
     try {
@@ -23,10 +23,9 @@ export default class PendingOwnerInviteRow extends Component {
         this.notifications.error('Error in accepting invite');
       }
     }
-  })
-  acceptInvitationTask;
+  }
 
-  @task(function* () {
+  @task *declineInvitationTask() {
     this.args.invite.set('accepted', false);
 
     try {
@@ -39,6 +38,5 @@ export default class PendingOwnerInviteRow extends Component {
         this.notifications.error('Error in declining invite');
       }
     }
-  })
-  declineInvitationTask;
+  }
 }

app/components/settings/api-tokens.js

@@ -19,7 +19,7 @@ export default class ApiTokens extends Component {
     this.newToken = this.store.createRecord('api-token');
   }
 
-  @task(function* () {
+  @task *saveTokenTask() {
     let token = this.newToken;
 
     try {
@@ -34,10 +34,9 @@ export default class ApiTokens extends Component {
 
       this.notifications.error(msg);
     }
-  })
-  saveTokenTask;
+  }
 
-  @task(function* (token) {
+  @task *revokeTokenTask(token) {
     try {
       yield token.destroyRecord();
       this.args.tokens.removeObject(token);
@@ -49,6 +48,5 @@ export default class ApiTokens extends Component {
 
       this.notifications.error(msg);
     }
-  })
-  revokeTokenTask;
+  }
 }

app/controllers/crate/settings.js

@@ -9,7 +9,7 @@ export default class CrateSettingsController extends Controller {
   crate = null;
   username = '';
 
-  @task(function* () {
+  @task *addOwnerTask() {
     const username = this.username;
 
     try {
@@ -22,10 +22,8 @@ export default class CrateSettingsController extends Controller {
         this.notifications.error('Error sending invite');
       }
     }
-  })
-  addOwnerTask;
-
-  @task(function* (owner) {
+  }
+  @task *removeOwnerTask(owner) {
     try {
       yield this.crate.removeOwner(owner.get('login'));
 
@@ -45,6 +43,5 @@ export default class CrateSettingsController extends Controller {
 
       this.notifications.error(message);
     }
-  })
-  removeOwnerTask;
+  }
 }

app/controllers/crate/version.js

@@ -25,7 +25,7 @@ export default class CrateVersionController extends Controller {
 
   @alias('loadReadmeTask.last.value') readme;
 
-  @task(function* () {
+  @task *loadReadmeTask() {
     let version = this.currentVersion;
 
     let readme = version.loadReadmeTask.lastSuccessful
@@ -41,6 +41,5 @@ export default class CrateVersionController extends Controller {
     }
 
     return readme;
-  })
-  loadReadmeTask;
+  }
 }

app/controllers/dashboard.js

@@ -37,14 +37,13 @@ export default class DashboardController extends Controller {
     return this.myFollowing.length > TO_SHOW;
   }
 
-  @task(function* () {
+  @task *loadMoreTask() {
     let page = this.myFeed.length / 10 + 1;
 
     let data = yield ajax(`/api/v1/me/updates?page=${page}`);
     let versions = data.versions.map(version => this.store.push(this.store.normalize('version', version)));
 
     this.myFeed.pushObjects(versions);
     this.set('hasMore', data.meta.more);
-  })
-  loadMoreTask;
+  }
 }

app/models/version.js

@@ -124,10 +124,9 @@ export default class Version extends Model {
   }).keepLatest())
   loadReadmeTask;
 
-  @task(function* () {
+  @task *loadDocsBuildsTask() {
     return yield ajax(`https://docs.rs/crate/${this.crateName}/${this.num}/builds.json`);
-  })
-  loadDocsBuildsTask;
+  }
 
   @computed('loadDocsBuildsTask.lastSuccessful.value')
   get hasDocsRsLink() {

app/routes/application.js

@@ -45,9 +45,8 @@ export default class ApplicationRoute extends Route {
     return true;
   }
 
-  @task(function* () {
+  @task *preloadPlaygroundCratesTask() {
     yield rawTimeout(1000);
     yield this.playground.loadCratesTask.perform();
-  })
-  preloadPlaygroundCratesTask;
+  }
 }

app/services/progress.js

@@ -3,7 +3,7 @@ import { htmlSafe } from '@ember/template';
 import { tracked } from '@glimmer/tracking';
 import Ember from 'ember';
 
-import { didCancel, rawTimeout, task } from 'ember-concurrency';
+import { didCancel, dropTask, rawTimeout, task } from 'ember-concurrency';
 
 const SPEED = 200;
 
@@ -24,7 +24,7 @@ export default class ProgressService extends Service {
     });
   }
 
-  @task(function* (promise) {
+  @task *counterTask(promise) {
     this.updateTask.perform().catch(error => {
       if (!didCancel(error)) {
         // this task shouldn't be able to fail, but if it does we'll let Sentry know
@@ -33,10 +33,9 @@ export default class ProgressService extends Service {
     });
 
     yield promise;
-  })
-  counterTask;
+  }
 
-  @(task(function* () {
+  @dropTask *updateTask() {
     if (Ember.testing) return;
 
     let progress = 0;
@@ -69,6 +68,5 @@ export default class ProgressService extends Service {
     this._style = `transition: width ${SPEED}ms linear; width: 100%`;
     yield rawTimeout(SPEED);
     this._style = `transition: opacity ${SPEED * 2}ms linear; width: 100%; opacity: 0`;
-  }).drop())
-  updateTask;
+  }
 }

app/services/session.js

@@ -1,7 +1,7 @@
 import { alias } from '@ember/object/computed';
 import Service, { inject as service } from '@ember/service';
 
-import { race, rawTimeout, task, waitForEvent } from 'ember-concurrency';
+import { dropTask, race, rawTimeout, task, waitForEvent } from 'ember-concurrency';
 import window from 'ember-window-mock';
 
 import ajax from '../utils/ajax';
@@ -46,7 +46,7 @@ export default class SessionService extends Service {
    * @see https://developer.github.com/v3/oauth/#redirect-users-to-request-github-access
    * @see `github-authorize` route
    */
-  @task(function* () {
+  @task *loginTask() {
     let windowDimensions = [
       'width=1000',
       'height=450',
@@ -109,20 +109,18 @@ export default class SessionService extends Service {
     if (transition) {
       transition.retry();
     }
-  })
-  loginTask;
+  }
 
-  @task(function* (window) {
+  @task *windowCloseWatcherTask(window) {
     while (true) {
       if (window.closed) {
         return { closed: true };
       }
       yield rawTimeout(10);
     }
-  })
-  windowCloseWatcherTask;
+  }
 
-  @task(function* () {
+  @task *logoutTask() {
     yield ajax(`/api/private/session`, { method: 'DELETE' });
 
     this.savedTransition = null;
@@ -132,10 +130,9 @@ export default class SessionService extends Service {
     this.sentry.setUser(null);
 
     this.router.transitionTo('index');
-  })
-  logoutTask;
+  }
 
-  @(task(function* () {
+  @dropTask *loadUserTask() {
     if (!this.isLoggedIn) return {};
 
     let response;
@@ -152,6 +149,5 @@ export default class SessionService extends Service {
     this.sentry.setUser({ id });
 
     return { currentUser, ownedCrates };
-  }).drop())
-  loadUserTask;
+  }
 }