pub struct MinerListener { /* private fields */ }Implementations§
Source§impl MinerListener
impl MinerListener
pub fn new() -> Self
Sourcepub async fn listen(
&self,
) -> Pin<Box<dyn Stream<Item = Result<Option<Box<dyn Miner>>>> + '_>>
pub async fn listen( &self, ) -> Pin<Box<dyn Stream<Item = Result<Option<Box<dyn Miner>>>> + '_>>
Listen for miners on the network.
§Examples
use asic_rs::miners::listener::MinerListener;
use futures::pin_mut;
use tokio_stream::StreamExt;
#[tokio::main]
async fn main() -> () {
let listener = MinerListener::new();
let stream = listener.listen().await;
pin_mut!(stream);
while let Some(miner) = stream.next().await {
println!("Found miner: {miner:?}")
}
}Trait Implementations§
Auto Trait Implementations§
impl Freeze for MinerListener
impl RefUnwindSafe for MinerListener
impl Send for MinerListener
impl Sync for MinerListener
impl Unpin for MinerListener
impl UnwindSafe for MinerListener
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more