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 1b5df0eac9013f7e2f88408e365681c4b75228da Author: João Ferreira <[email protected]> AuthorDate: Mon Aug 21 11:14:26 2023 +0100 applyCodeStyle --- .../connectors/kinesis/impl/KinesisSchedulerSourceStage.scala | 11 ++++++----- 1 file changed, 6 insertions(+), 5 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 5c520c8ae..b72922b1f 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 @@ -81,11 +81,11 @@ private[kinesis] class KinesisSchedulerSourceStage( override def shardRecordProcessor(): ShardRecordProcessor = new ShardProcessor(newRecordCallback) }) - //Run the scheduler loop in a separate thread + // Run the scheduler loop in a separate thread val thread = new Thread(() => { - val result = Try {scheduler.run()} - callback.invoke(SchedulerShutdown(result)) - }, s"KinesisSchedulerSource") + val result = Try { scheduler.run() } + callback.invoke(SchedulerShutdown(result)) + }, s"KinesisSchedulerSource") thread.setDaemon(true) thread.start() schedulerOpt = Some(scheduler) @@ -117,6 +117,7 @@ private[kinesis] class KinesisSchedulerSourceStage( failStage(SchedulerUnexpectedShutdown(e)) } override def postStop(): Unit = - schedulerOpt.foreach(scheduler => Future(if (!scheduler.shutdownComplete()) scheduler.shutdown())(materializer.executionContext)) + schedulerOpt.foreach(scheduler => + Future(if (!scheduler.shutdownComplete()) scheduler.shutdown())(materializer.executionContext)) } } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
