blockworks-foundation
/
geyser-grpc-connector
mirror of https://github.com/blockworks-foundation/geyser-grpc-connector.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

clippy+fmt

This commit is contained in:
GroovieGermanikus 2024-01-26 19:25:57 +01:00
parent 68221ce0cc
commit 1ddd4bd24a
No known key found for this signature in database
GPG Key ID: 5B6EB831A5CD2015
2 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
examples/stream_blocks_autoconnect.rs
View File

@ -1,9 +1,8 @@
use futures::{Stream, StreamExt}; use futures::StreamExt;
use log::info; use log::info;
use solana_sdk::clock::Slot; use solana_sdk::clock::Slot;
use solana_sdk::commitment_config::CommitmentConfig; use solana_sdk::commitment_config::CommitmentConfig;
use std::env; use std::env;
use std::pin::pin;
use geyser_grpc_connector::channel_plugger::spawn_broadcast_channel_plug; use geyser_grpc_connector::channel_plugger::spawn_broadcast_channel_plug;
use geyser_grpc_connector::grpc_subscription_autoreconnect_tasks::create_geyser_autoconnection_task; use geyser_grpc_connector::grpc_subscription_autoreconnect_tasks::create_geyser_autoconnection_task;

4
examples/stream_blocks_single.rs
View File

@ -6,9 +6,7 @@ use std::env;
use std::pin::pin; use std::pin::pin;
use geyser_grpc_connector::grpc_subscription_autoreconnect_streams::create_geyser_reconnecting_stream; use geyser_grpc_connector::grpc_subscription_autoreconnect_streams::create_geyser_reconnecting_stream;
use geyser_grpc_connector::grpcmultiplex_fastestwins::{ use geyser_grpc_connector::grpcmultiplex_fastestwins::FromYellowstoneExtractor;
create_multiplexed_stream, FromYellowstoneExtractor,
};
use geyser_grpc_connector::{GeyserFilter, GrpcConnectionTimeouts, GrpcSourceConfig, Message}; use geyser_grpc_connector::{GeyserFilter, GrpcConnectionTimeouts, GrpcSourceConfig, Message};
use tokio::time::{sleep, Duration}; use tokio::time::{sleep, Duration};
use tracing::warn; use tracing::warn;