Function activityIndicatorStream

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>>