Function messageSyncTopicStream

Returns (<T extends RealtimeMessage<any, T>>(source$: Observable<T>) => Observable<DirectThreadEvent<any>>)

• • <T extends RealtimeMessage<any, T>>(source$: Observable<T>): Observable<DirectThreadEvent<any>>

  • Type Parameters

    • T extends RealtimeMessage<any, T>

    Parameters

    • source$: Observable<T>

    Returns Observable<DirectThreadEvent<any>>