Remove rayon from rest_api

sigp · Aug 24, 2020 · adc0b93 · adc0b93
1 parent c895dc8
commit adc0b93
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 5 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/beacon_node/rest_api/Cargo.toml b/beacon_node/rest_api/Cargo.toml
@@ -34,7 +34,6 @@ hex = "0.4.2"
 parking_lot = "0.11.0"
 futures = "0.3.5"
 operation_pool = { path = "../operation_pool" }
-rayon = "1.3.0"
 environment = { path = "../../lighthouse/environment" }
 uhttp_sse = "0.5.1"
 bus = "2.2.3"

diff --git a/beacon_node/rest_api/src/validator.rs b/beacon_node/rest_api/src/validator.rs
@@ -8,7 +8,6 @@ use bls::PublicKeyBytes;
 use eth2_libp2p::PubsubMessage;
 use hyper::Request;
 use network::NetworkMessage;
-use rayon::prelude::*;
 use rest_types::{ValidatorDutiesRequest, ValidatorDutyBytes, ValidatorSubscription};
 use slog::{error, info, trace, warn, Logger};
 use std::sync::Arc;
@@ -437,7 +436,7 @@ pub fn publish_attestations<T: BeaconChainTypes>(
         .map(
             move |attestations: Vec<(Attestation<T::EthSpec>, SubnetId)>| {
                 attestations
-                    .into_par_iter()
+                    .into_iter()
                     .enumerate()
                     .map(|(i, (attestation, subnet_id))| {
                         process_unaggregated_attestation(
@@ -546,7 +545,7 @@ pub fn publish_aggregate_and_proofs<T: BeaconChainTypes>(
         .map(
             move |signed_aggregates: Vec<SignedAggregateAndProof<T::EthSpec>>| {
                 signed_aggregates
-                    .into_par_iter()
+                    .into_iter()
                     .enumerate()
                     .map(|(i, signed_aggregate)| {
                         process_aggregated_attestation(