10 examples of 'apollo usesubscription' in JavaScript

4
export default function useQueryAndSubscription(query, subscription) {
5
  const {loading, data: queryData, error} = useQuery(...query);
6
  const {data: subData} = useSubscription(...subscription);
7
  const queryName =
8
    query[0].definitions[0].selectionSet.selections[0].name.value;
9
  const subName =
10
    subscription[0].definitions[0].selectionSet.selections[0].name.value;
11
12
  const data = subData ? {[queryName]: subData[subName]} : queryData;
13
14
  return {loading, data, error};
15
}

274
public subscribe(options: SubscriptionOptions): Observable {
275
  this.initQueryManager();
276
277
  return this.queryManager.startGraphQLSubscription(options);
278
}

102
request(operation = {}) {
103
  const clientContext = getClientContext(operation, this.clientContextKey);
104
  const subHandler = this.connection.subscribe(this.publication, operation, clientContext);
105
  const subId = subHandler[this.subscriptionIdKey];
106
107
  return new Observable((observer) => {
108
    this.subscriptionObservers.set(subId, observer);
109
110
    return () => {
111
      if (subHandler.stop) {
112
        subHandler.stop();
113
      } else if (this.connection.unsubscribe) {
114
        this.connection.unsubscribe(subId);
115
      } else {
116
        console.warn(`ddp-apollo: could not unsubscribe from subscription with ID ${subId}`);
117
      }
118
      this.subscriptionObservers.delete(subId);
119
    };
120
  });
121
}

14
export function useSubscription(value$: Observable, defaultValue: T) {
15
  const [value, setValue] = useState(defaultValue);
16
  useEffect(
17
    () => {
18
      const subscription = value$.subscribe(value => {
19
        setValue(value);
20
      });
21
      return () => subscription.unsubscribe();
22
    },
23
    [value$, setValue],
24
  );
25
  return value;
26
}

15
public request(_req: any) {
16
  return new Observable(observer => {
17
    this.setups.forEach(x => x());
18
    this.observer = observer;
19
    return () => {
20
      this.unsubscribers.forEach(x => x());
21
    };
22
  });
23
}

56
export function useApolloMutation(mutation, baseOptions) {
57
  const client = useApolloClient();
58
  return localOptions =>
59
    client.mutate({ mutation, ...baseOptions, ...localOptions });
60
}

154
public default(): ApolloBase {
155
  return this;
156
}

16
provide (key = '$apolloProvider') {
17
  console.warn(`.provide() is deprecated. Use the 'apolloProvider' option instead with the provider object directly.`)
18
  return {
19
    [key]: this,
20
  }
21
}

55
function useDataSubscription(subscription: SubscriptionTarget): ObservedData {
56
  const subscriptions = React.useMemo(() => [subscription], [subscription])
57
  return useDataSubscriptions(subscriptions)[0]
58
}

28
export function useSubscriptionEffect(event$: Observable, callback: (value: T) => void) {
29
  useEffect(
30
    () => {
31
      const subscription = event$.subscribe(value => {
32
        callback(value);
33
      });
34
      return () => subscription.unsubscribe();
35
    },
36
    [event$, callback],
37
  );
38
}