This is an automated email from the ASF dual-hosted git repository. mdedetrich pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/incubator-pekko-connectors.git
commit 67a3fd682ffe00cdd6f7f72dbc3e0588db08952c Author: João Ferreira <[email protected]> AuthorDate: Fri Feb 9 22:45:14 2024 +0000 scalafmt --- .../stream/connectors/kinesis/impl/KinesisSchedulerSourceStage.scala | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/impl/KinesisSchedulerSourceStage.scala b/kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/impl/KinesisSchedulerSourceStage.scala index 929bfcb6c..527cebf93 100644 --- a/kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/impl/KinesisSchedulerSourceStage.scala +++ b/kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/impl/KinesisSchedulerSourceStage.scala @@ -113,8 +113,7 @@ private[kinesis] class KinesisSchedulerSourceStage( } override def postStop(): Unit = schedulerOpt.foreach(scheduler => - if (!scheduler.shutdownComplete()) scheduler.shutdown() - ) + if (!scheduler.shutdownComplete()) scheduler.shutdown()) protected def executionContext(attributes: Attributes): ExecutionContext = { val dispatcherId = (attributes.get[ActorAttributes.Dispatcher](ActorAttributes.IODispatcher) match { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
