Skip to content

Commit

Permalink
remove unused parameter
Browse files Browse the repository at this point in the history
Signed-off-by: Klem Yannic (INST/ECS1) <yannic.klem@bosch-si.com>
  • Loading branch information
Yannic92 committed Feb 27, 2020
1 parent 573b863 commit b8674f1
Showing 1 changed file with 2 additions and 3 deletions.
Expand Up @@ -66,7 +66,7 @@ private EnforcerActor(final ActorRef pubSubMediator,
super(pubSubMediator, conciergeForwarder, partitionBufferSize, thingIdCache, aclEnforcerCache,
policyEnforcerCache);

handler = assembleHandler(enforcementProviders, preEnforcer, partitionBufferSize);
handler = assembleHandler(enforcementProviders, preEnforcer);
sink = assembleSink();
}

Expand Down Expand Up @@ -142,8 +142,7 @@ protected Flow<Contextual<WithDittoHeaders>, Contextual<WithDittoHeaders>, NotUs
@SuppressWarnings("unchecked") // due to GraphDSL usage
private Flow<Contextual<WithDittoHeaders>, Contextual<WithDittoHeaders>, NotUsed> assembleHandler(
final Set<EnforcementProvider<?>> enforcementProviders,
@Nullable final Function<WithDittoHeaders, CompletionStage<WithDittoHeaders>> preEnforcer,
final int partitionBufferSize) {
@Nullable final Function<WithDittoHeaders, CompletionStage<WithDittoHeaders>> preEnforcer) {

final Graph<FlowShape<Contextual<WithDittoHeaders>, Contextual<WithDittoHeaders>>, NotUsed> preEnforcerFlow =
Optional.ofNullable(preEnforcer)
Expand Down

0 comments on commit b8674f1

Please sign in to comment.