dynamo-subscriber
Subscribe DynamoDB Streams as tokio-stream.
Overview
This library is a wrapper of DynamoDB Streams and enables using it as a tokio-stream. If you want to know what tokio-stream is and how to use it, see this doc.
Example
In this example, the stream object subscribes dynamodb stream and receives records from it.
[]
= "0.1.0"
= "1.0.1"
= { = "1", = ["macros", "rt-multi-thread"] }
= "0.1.14"
use BehaviorVersion;
use dynamo_subscriber as subscriber;
use StreamExt;
// This example assumes that the dynamodb-local instance is running on localhost:8000
// and "People" table exists.
async
License
This project is licensed under the MIT license.