transformChannelInboundMessages

transformChannelInboundMessages<TOutboundMessage, TNewInboundMessage, TInboundMessage>(channel, transform): RpcSubscriptionsChannel<TOutboundMessage, TNewInboundMessage>

Given a channel with inbound messages of type T and a function of type T => U, returns a new channel with inbound messages of type U.

Note that this only affects messages of type "message" and thus, does not affect incoming error messages.

Type Parameters

Parameters

Returns

RpcSubscriptionsChannel<TOutboundMessage, TNewInboundMessage>

Example

const transformedChannel = transformChannelInboundMessages(channel, JSON.parse);