Let commands = sqlx::query_file_as!(CommandRecord, "sql/select_command.sql").fetch(&pool); commands .map_ok(|record| ->

Question

Let commands = sqlx::query_file_as!(CommandRecord, "sql/select_command.sql").fetch(&pool); commands .map_ok(|record| ->

Result<()> {
let imei = record.imei.parse::<i32>()?;
let command: protos::command::Command = record.try_into()?;
let command = protobuf::Message::write_to_bytes(&command)?;
let clients = match clients.lock() {
Ok(clients) => clients,
Err(err) => err.into_inner(),
};
if let Some(client) = clients.get(&imei) {
client.unbounded_send(Message::Binary(command))?
};
Ok(())
})
.filter(|res| if Ok() = res { true } else { print; false } )
.for_each(|_| future::ready(()))
.await;