Class DefaultLinkStrategy

Default implementation of LinkStrategyInterface.

Extends BaseLinkingStrategy and implements link with standard capability-based dispatch: inspects flags on both transfers and selects the matching sync or async linking strategy.

Example

const linkStrategy = new DefaultLinkStrategy();
const subscriber = linkStrategy.link(source, target);

Hierarchy

BaseLinkingStrategy
- DefaultLinkStrategy

Index

Linking

_throwLinkAsyncPullableToPollingProxyError _throwLinkPullableToPushableError

Other

constructor _linkAsyncPullableToAsyncPollingProxy _linkPullableToAsyncPollingProxy _linkPullableToPollingProxy _linkSubscribableToAsyncPollingProxy _linkSubscribableToAsyncPushable _linkSubscribableToPollingProxy _linkSubscribableToPushable _throwLinkUnsupportedError link

Linking

`Protected`_throwLinkAsyncPullableToPollingProxyError

_throwLinkAsyncPullableToPollingProxyError(): never
Throws an error for an unsupported asyncPullable → sync-pollingProxy link.

Returns never
- Defined in linking.ts:246

`Protected`_throwLinkPullableToPushableError

_throwLinkPullableToPushableError(): never
Throws an error for an unsupported pullable/asyncPullable → pushable/asyncPushable link.

Returns never
- Defined in linking.ts:257

Other

constructor

new DefaultLinkStrategy(): DefaultLinkStrategy

Returns DefaultLinkStrategy

Inherited from BaseLinkingStrategy.constructor

`Protected`_linkAsyncPullableToAsyncPollingProxy

_linkAsyncPullableToAsyncPollingProxy<T>(
lhs: AsyncPullable<T>,
rhs: AsyncPollingProxy<T>,
): SubscriberInterface
Type Parameters
- T
Parameters
- lhs: AsyncPullable<T>
- rhs: AsyncPollingProxy<T>
Returns SubscriberInterface
Inherited from BaseLinkingStrategy._linkAsyncPullableToAsyncPollingProxy
- Defined in linking.ts:91

`Protected`_linkPullableToAsyncPollingProxy

_linkPullableToAsyncPollingProxy<T>(
lhs: Pullable<T>,
rhs: AsyncPollingProxy<T>,
): SubscriberInterface
Type Parameters
- T
Parameters
- lhs: Pullable<T>
- rhs: AsyncPollingProxy<T>
Returns SubscriberInterface
Inherited from BaseLinkingStrategy._linkPullableToAsyncPollingProxy
- Defined in linking.ts:98

`Protected`_linkPullableToPollingProxy

_linkPullableToPollingProxy<T>(
lhs: Pullable<T>,
rhs: PollingProxy<T>,
): SubscriberInterface
Type Parameters
- T
Parameters
- lhs: Pullable<T>
- rhs: PollingProxy<T>
Returns SubscriberInterface
Inherited from BaseLinkingStrategy._linkPullableToPollingProxy
- Defined in linking.ts:53

`Protected`_linkSubscribableToAsyncPollingProxy

_linkSubscribableToAsyncPollingProxy<T>(
lhs: Subscribable<T>,
rhs: AsyncPollingProxy<T>,
): SubscriberInterface
Type Parameters
- T
Parameters
- lhs: Subscribable<T>
- rhs: AsyncPollingProxy<T>
Returns SubscriberInterface
Inherited from BaseLinkingStrategy._linkSubscribableToAsyncPollingProxy
- Defined in linking.ts:105

`Protected`_linkSubscribableToAsyncPushable

_linkSubscribableToAsyncPushable<T>(
    lhs: Subscribable<T>,
    rhs: AsyncPushable<T>,
    onError?: ErrorHandler<AsyncPushable<T>>,
): SubscriberInterface
Type Parameters
- T
Parameters
- lhs: Subscribable<T>
- rhs: AsyncPushable<T>
- OptionalonError: ErrorHandler<AsyncPushable<T>>
Returns SubscriberInterface
Inherited from BaseLinkingStrategy._linkSubscribableToAsyncPushable
- Defined in linking.ts:79

`Protected`_linkSubscribableToPollingProxy

_linkSubscribableToPollingProxy<T>(
lhs: Subscribable<T>,
rhs: PollingProxy<T>,
): SubscriberInterface
Type Parameters
- T
Parameters
- lhs: Subscribable<T>
- rhs: PollingProxy<T>
Returns SubscriberInterface
Inherited from BaseLinkingStrategy._linkSubscribableToPollingProxy
- Defined in linking.ts:60

`Protected`_linkSubscribableToPushable

_linkSubscribableToPushable<T>(
lhs: Subscribable<T>,
rhs: Pushable<T>,
): SubscriberInterface
Type Parameters
- T
Parameters
- lhs: Subscribable<T>
- rhs: Pushable<T>
Returns SubscriberInterface
Inherited from BaseLinkingStrategy._linkSubscribableToPushable
- Defined in linking.ts:49

`Protected`_throwLinkUnsupportedError

_throwLinkUnsupportedError(
lhs: CommunicationContractInterface,
rhs: CommunicationContractInterface,
): never
Parameters
- lhs: CommunicationContractInterface
- rhs: CommunicationContractInterface
Returns never
Inherited from BaseLinkingStrategy._throwLinkUnsupportedError
- Defined in linking.ts:124

link

link<T, RTransfer extends InputTransfer<T>>(
    lhs: OutputTransfer<T>,
    rhs: RTransfer,
    options?: LinkConfig<RTransfer>,
): SubscriberInterface
Links an output transfer to an input transfer.

The strategy is determined by capability flags. Sync strategies take priority over async ones. See linkTransfers for the full strategy matrix.
Type Parameters
- T
  — data type flowing through the link
- RTransfer extends InputTransfer<T>
  — type of the input transfer (RHS)
Parameters
- lhs: OutputTransfer<T>
  — output transfer (source)
- rhs: RTransfer
  — input transfer (sink)
- Optionaloptions: LinkConfig<RTransfer>
  — optional link config (onError for async-push rejection)
Returns SubscriberInterface
SubscriberInterface for breaking the link
Overrides BaseLinkingStrategy.link
- Defined in linking.ts:164

Class DefaultLinkStrategy

Example

Hierarchy

Index

Linking

Other

Linking

Protected_throwLinkAsyncPullableToPollingProxyError

Returns never

Protected_throwLinkPullableToPushableError

Returns never

Other

constructor

Returns DefaultLinkStrategy

Protected_linkAsyncPullableToAsyncPollingProxy

Type Parameters

Parameters

Returns SubscriberInterface

Protected_linkPullableToAsyncPollingProxy

Type Parameters

Parameters

Returns SubscriberInterface

Protected_linkPullableToPollingProxy

Type Parameters

Parameters

Returns SubscriberInterface

Protected_linkSubscribableToAsyncPollingProxy

Type Parameters

Parameters

Returns SubscriberInterface

Protected_linkSubscribableToAsyncPushable

Type Parameters

Parameters

Returns SubscriberInterface

Protected_linkSubscribableToPollingProxy

Type Parameters

Parameters

Returns SubscriberInterface

Protected_linkSubscribableToPushable

Type Parameters

Parameters

Returns SubscriberInterface

Protected_throwLinkUnsupportedError

Parameters

Returns never

link

Type Parameters

Parameters

Returns SubscriberInterface

Settings

On This Page

`Protected`_throwLinkAsyncPullableToPollingProxyError

`Protected`_throwLinkPullableToPushableError

`Protected`_linkAsyncPullableToAsyncPollingProxy

`Protected`_linkPullableToAsyncPollingProxy

`Protected`_linkPullableToPollingProxy

`Protected`_linkSubscribableToAsyncPollingProxy

`Protected`_linkSubscribableToAsyncPushable

`Protected`_linkSubscribableToPollingProxy

`Protected`_linkSubscribableToPushable

`Protected`_throwLinkUnsupportedError