Function groupByRelays

  • groupByRelays<T>(defaultRelay): OperatorFunction<T, GroupedObservable<string, T>>

  • Splits a stream of messages out into relay specific observables

    Type Parameters

    • T extends Message

    Parameters

    • defaultRelay: string

    Returns OperatorFunction<T, GroupedObservable<string, T>>

Settings

Member Visibility