Function executeRpcPubSubSubscriptionPlan

  • executeRpcPubSubSubscriptionPlan<TNotification>(
        __namedParameters: Readonly<
            {
                channel: RpcSubscriptionsChannel<
                    unknown,
                    | RpcResponseData<number>
                    | Readonly<
                        {
                            method: string;
                            params: Readonly<{ result: TNotification; subscription: number }>;
                        },
                    >,
                >;
                responseTransformer?: RpcResponseTransformer;
                signal: AbortSignal;
                subscribeRequest: RpcRequest;
                unsubscribeMethodName: string;
            },
        >,
    ): Promise<DataPublisher<RpcSubscriptionNotificationEvents<TNotification>>>

  • Type Parameters

    • TNotification

    Parameters

    • __namedParameters: Readonly<
          {
              channel: RpcSubscriptionsChannel<
                  unknown,
                  | RpcResponseData<number>
                  | Readonly<
                      {
                          method: string;
                          params: Readonly<{ result: TNotification; subscription: number }>;
                      },
                  >,
              >;
              responseTransformer?: RpcResponseTransformer;
              signal: AbortSignal;
              subscribeRequest: RpcRequest;
              unsubscribeMethodName: string;
          },
      >

    Returns Promise<DataPublisher<RpcSubscriptionNotificationEvents<TNotification>>>

Settings

Member Visibility