git.delta.rocks / unique-network / refs/commits / 2d2fd30b7a2b

no syntactic changes

27use futures::{Stream, StreamExt, stream::select, task::{Context, Poll}};27use futures::{
28	Stream, StreamExt,
29	stream::select,
30	task::{Context, Poll},
31};
28use futures_timer::Delay;32use futures_timer::Delay;
2933
127131
128		Ok(Self {132		Ok(Self {
129			duration,133			duration,
130			delay_handle: Box::pin(Delay::new(duration))134			delay_handle: Box::pin(Delay::new(duration)),
131		})135		})
132	}136	}
133}137}
143147
144				Poll::Ready(Some(()))148				Poll::Ready(Some(()))
145			}149			}
146			Poll::Pending => Poll::Pending150			Poll::Pending => Poll::Pending,
147		}151		}
148	}152	}
149}153}
837		);841		);
838842
839		let transactions_commands_stream: Box<dyn Stream<Item = EngineCommand<Hash>> + Send + Sync + Unpin> =843		let transactions_commands_stream: Box<
844			dyn Stream<Item = EngineCommand<Hash>> + Send + Sync + Unpin,
840			Box::new(845		> = Box::new(
841				transaction_pool846			transaction_pool
842					.pool()847				.pool()
852857
853		let autoseal_interval = Box::pin(autoseal_interval);858		let autoseal_interval = Box::pin(autoseal_interval);
854		let idle_commands_stream: Box<dyn Stream<Item = EngineCommand<Hash>> + Send + Sync + Unpin> =859		let idle_commands_stream: Box<
860			dyn Stream<Item = EngineCommand<Hash>> + Send + Sync + Unpin,
855			Box::new(861		> = Box::new(autoseal_interval.map(|_| EngineCommand::SealNewBlock {
856				autoseal_interval.map(|_| EngineCommand::SealNewBlock {
857					create_empty: true,862			create_empty: true,