Function activityIndicatorStream

activityIndicatorStream(topics: RealtimeTopic): (<T extends RealtimeMessage<any, T>>(source$: Observable<T>) => Observable<DirectThreadEvent<ThreadActivityIndicatorPayload>>)
Parameters
- topics: RealtimeTopic
Returns (<T extends RealtimeMessage<any, T>>(source$: Observable<T>) => Observable<DirectThreadEvent<ThreadActivityIndicatorPayload>>)
- - <T extends RealtimeMessage<any, T>>(source$: Observable<T>): Observable<DirectThreadEvent<ThreadActivityIndicatorPayload>>
  - Type Parameters
    - T extends RealtimeMessage<any, T>
    Parameters
    - source$: Observable<T>
    Returns Observable<DirectThreadEvent<ThreadActivityIndicatorPayload>>