minor fix

Cargo.toml

@@ -1,5 +1,5 @@
 [package]
-name = "aws-msk-iam-sasl-signer-rs"
+name = "aws-msk-iam-sasl-signer"
 version = "0.1.0"
 edition = "2021"
 license = "Apache-2.0"

examples/consumer.rs

@@ -2,7 +2,7 @@ use std::thread;
 use std::time::Duration;
 
 use aws_config::Region;
-use aws_msk_iam_sasl_signer_rs::generate_auth_token;
+use aws_msk_iam_sasl_signer::generate_auth_token;
 use rdkafka::client::OAuthToken;
 use rdkafka::consumer::{Consumer, ConsumerContext, StreamConsumer};
 use rdkafka::{ClientConfig, ClientContext, Message};
@@ -67,7 +67,7 @@ async fn main() {
 
     let consumer: StreamConsumer<IamConsumerContext> = config.create_with_context(context).unwrap();
 
-    // consumer.recv().now_or_never().unwrap().unwrap();
+    // assert!(consumer.recv().now_or_never().is_none());
     // let partition_list = {
     //     let mut list = TopicPartitionList::new();
     //     let meta_data = consumer

examples/producer.rs

@@ -2,7 +2,7 @@ use std::thread;
 use std::time::Duration;
 
 use aws_config::Region;
-use aws_msk_iam_sasl_signer_rs::generate_auth_token;
+use aws_msk_iam_sasl_signer::generate_auth_token;
 use rdkafka::client::OAuthToken;
 use rdkafka::producer::{FutureProducer, FutureRecord, ProducerContext};
 use rdkafka::{ClientConfig, ClientContext};

src/lib.rs

@@ -101,10 +101,6 @@ async fn load_credentials_from_profile(
         .load()
         .await;
 
-    // if err != nil {
-    // 	return nil, fmt.Errorf("unable to load SDK config: %w", err)
-    // }
-
     load_credentials_from_credentials_provider(config.credentials_provider().unwrap()).await
 }