interface IGroup {
    event(event: Event): Observable<PublishResponse>;
    publish(
        event: Event,
        opts?: { retries?: number },
    ): Observable<PublishResponse>;
    req(filters: FilterInput, id?: string): Observable<SubscriptionResponse>;
    request(
        filters: FilterInput,
        opts?: { id?: string; retries?: number },
    ): Observable<Event>;
    subscription(
        filters: FilterInput,
        opts?: { id?: string; retries?: number },
    ): Observable<SubscriptionResponse>;
}

Hierarchy (View Summary)

Implemented by

Methods

  • Send a REQ message with retries

    Parameters

    • filters: FilterInput
    • Optionalopts: { id?: string; retries?: number }

    Returns Observable<Event>