Skip to content

WirelessDestinationEventSource

Source: src/AWS/Lambda/WirelessDestinationEventSource.ts

Connects an IoT Wireless Destination’s uplink traffic to the current Lambda function.

At deploy time this layer creates the IoT topic rule named by the destination’s expression (the destination must use expressionType: "RuleName") with a Lambda action targeting this function, and grants iot.amazonaws.com permission to invoke it; at runtime it dispatches uplink invocations to the registered handler.

yield* IoTWireless.consumeUplinks(destination, (uplinks) =>
uplinks.pipe(
Stream.runForEach((uplink) => Effect.log(uplink.PayloadData)),
Effect.orDie,
),
);