You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by md...@apache.org on 2024/02/23 07:40:22 UTC
(incubator-pekko-connectors) 03/11: applyCodeStyle
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 <jt...@gmail.com>
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: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org