resolved warning in connection

This commit is contained in:
michael-bailey 2022-09-25 12:27:07 +01:00
parent d9a6719162
commit db4af038d7
1 changed files with 11 additions and 4 deletions

View File

@ -1,11 +1,18 @@
use std::{io::Write, net::SocketAddr, pin::Pin, sync::Arc};
use actix::{
fut::wrap_future, Actor, ActorContext, Addr, AsyncContext, Context, Handler, Message,
Recipient, SpawnHandle,
fut::wrap_future,
Actor,
ActorContext,
Addr,
AsyncContext,
Context,
Handler,
Message,
Recipient,
SpawnHandle,
};
use futures::{future::join_all, Future, FutureExt};
use tokio::{
io::{split, AsyncBufReadExt, AsyncWriteExt, BufReader, ReadHalf, WriteHalf},
net::TcpStream,
@ -171,7 +178,7 @@ impl Handler<SelfMessage> for Connection {
match msg {
UpdateObserversWithData(data) => {
let send = ctx.address();
let addr = self.address.clone();
let addr = self.address;
// this is a mess
let futs: Vec<Pin<Box<dyn Future<Output = ()> + Send>>> = self
.observers