diff --git a/src/streaming/mod.rs b/src/streaming/mod.rs index b2f7a22..019ab5f 100755 --- a/src/streaming/mod.rs +++ b/src/streaming/mod.rs @@ -1,8 +1,8 @@ -pub mod yellow_stone; -pub mod yellow_stone_sub_system; +pub mod yellowstone_grpc; +pub mod yellowstone_sub_system; pub mod shred_stream; pub mod event_parser; -pub use yellow_stone::YellowstoneGrpc; -pub use yellow_stone_sub_system::{SystemEvent, TransferInfo}; +pub use yellowstone_grpc::YellowstoneGrpc; +pub use yellowstone_sub_system::{SystemEvent, TransferInfo}; pub use shred_stream::ShredStreamGrpc; \ No newline at end of file diff --git a/src/streaming/yellow_stone.rs b/src/streaming/yellowstone_grpc.rs similarity index 100% rename from src/streaming/yellow_stone.rs rename to src/streaming/yellowstone_grpc.rs diff --git a/src/streaming/yellow_stone_sub_system.rs b/src/streaming/yellowstone_sub_system.rs similarity index 94% rename from src/streaming/yellow_stone_sub_system.rs rename to src/streaming/yellowstone_sub_system.rs index b5db49b..f673e25 100755 --- a/src/streaming/yellow_stone_sub_system.rs +++ b/src/streaming/yellowstone_sub_system.rs @@ -1,8 +1,8 @@ -use crate::{common::AnyResult, streaming::yellow_stone::{TransactionPretty, YellowstoneGrpc}}; +use crate::{common::AnyResult, streaming::yellowstone_grpc::{TransactionPretty, YellowstoneGrpc}}; use solana_program::pubkey; use solana_sdk::{pubkey::Pubkey, transaction::VersionedTransaction}; -use futures::{channel::mpsc, sink::Sink, Stream, StreamExt, SinkExt}; -use log::{error, info}; +use futures::{channel::mpsc, StreamExt}; +use log::error; use solana_transaction_status::EncodedTransactionWithStatusMeta; const SYSTEM_PROGRAM_ID: Pubkey = pubkey!("11111111111111111111111111111111");