SharableSubscription<T>: {
    getSharableSubscriptionInternals: (() => Promise<EachTopic<T>>);
}

Type Parameters

  • T

Type declaration

  • getSharableSubscriptionInternals: (() => Promise<EachTopic<T>>)

    Used to replicate the multicast values at other sites. To manually create a local representative of a Subscription, do

    localIterable =
    makeSubscription(E(remoteIterable).getSharableSubscriptionInternals());

    The resulting localIterable also supports such remote use, and will return access to the same representation.