10 examples of 'angular wait for subscribe to finish' in JavaScript

62
function subscribe() {
63
	if (client == null || !client.connected) {
64
		alert("Please connect first!");
65
		return;
66
	}
67
	if (subscription != null) {
68
		subscription.unsubscribe();
69
	}
70
	var subInfo = document.forms["subForm"];
71
	subscription = client.subscribe(subInfo["destination"].value, onMessage, {ack: "auto"});
72
	alert("Subscription ID: " + subscription["id"]);
73
}

94
SimplePush.subscribe(function onSubscribe(err, data) {
95
  if (err) {
96
    alert(err);
97
  }
98
99
  console.log('Subscribed :: ' + JSON.stringify(data));
100
});

27
function subscribe() {
28
  vm.frm = {};
29
  if (!vm.email || vm.email.trim().length === 0) {
30
    vm.frm.email = {error : true};
31
    $scope.$apply();
32
    return false;
33
  }
34
  $scope.$apply();
35
  return true;
36
}

11
orsMessagingService.subscribeToMessage(function onNext(message) {
12
  if (message.color >= -1) {
13
    ctrl.show = true;
14
    ctrl.message = {};
15
    if (message.translate) ctrl.message.translate = message.translate;
16
    if (message.text) ctrl.message.text = message.text;
17
    switch (message.color) {
18
      case -1:
19
        ctrl.message.color = "red";
20
        break;
21
      case 0:
22
        ctrl.message.color = "orange";
23
        break;
24
      case 1:
25
        ctrl.message.color = "blue";
26
        break;
27
      case 2:
28
        ctrl.message.color = "green";
29
        break;
30
      default:
31
        break;
32
    }
33
34
    $timeout(function() {
35
      ctrl.show = false;
36
    }, 5000);
37
  }
38
});

18
function subscribeForData() {
19
  if (dataSubscriptions) {
20
    return dataSubscriptions;
21
  }
22
23
  const subNames = [
24
    'users', 'chat', 'cursor', 'deskshare', 'meetings',
25
    'polls', 'presentations', 'shapes', 'slides', 'captions', 'breakouts',
26
  ];
27
28
  let subs = [];
29
  subNames.forEach(name => subs.push(subscribeFor(name)));
30
31
  dataSubscriptions = subs;
32
  return subs;
33
};

14
addSubscription(subscription: Subscription): void {
15
    this._subscriptions.push(subscription);
16
}

292
initWebsocketSubscriptions() {
293
  this.isAlive = true;
294
  this.websocketProjectEventSubscription();
295
  this.websocketScreenEventSubscription();
296
}

22
subscribe( spy ) {
23
  this.obs = new Subject().pipe(untilDestroyed(this)).subscribe(spy);
24
}

77
private waitForData(resolve: any) {
78
    this.stream.once('end', () => {
79
        Logger.debug(`Uds server detected stream's end`);
80
        resolve();
81
        return;
82
    });
83
84
    this.stream.on('data', (msg: any) => {
85
        Logger.debug(`Uds server got data`);
86
        resolve({payload: msg});
87
    });
88
}

153
public subscribe(): void {
154
155
  // Subscribe to our configured queues
156
  for (let t of this.config.subscribe) {
157
    this.client.subscribe(t, this.on_message, { ack: 'auto' });
158
  }
159
160
  // Update the state
161
  if (this.config.subscribe.length > 0) {
162
    this.state.next(STOMPState.SUBSCRIBED);
163
  }
164
}