You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by se...@apache.org on 2023/01/15 03:52:49 UTC
[incubator-pekko-connectors-kafka] branch seglo/prep-scalafmt created (now 81ee9ad9)
This is an automated email from the ASF dual-hosted git repository.
seanglover pushed a change to branch seglo/prep-scalafmt
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-connectors-kafka.git
at 81ee9ad9 drop private return type
This branch includes the following new commits:
new 81ee9ad9 drop private return type
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org
[incubator-pekko-connectors-kafka] 01/01: drop private return type
Posted by se...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
seanglover pushed a commit to branch seglo/prep-scalafmt
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-connectors-kafka.git
commit 81ee9ad94995c4b0d79a5a0ea1990e65c2f7e6e2
Author: Sean Glover <se...@seanglover.com>
AuthorDate: Sat Jan 14 22:52:35 2023 -0500
drop private return type
---
.../test/scala/akka/kafka/internal/CommitCollectorStageSpec.scala | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
diff --git a/tests/src/test/scala/akka/kafka/internal/CommitCollectorStageSpec.scala b/tests/src/test/scala/akka/kafka/internal/CommitCollectorStageSpec.scala
index f4863658..1d54d41e 100644
--- a/tests/src/test/scala/akka/kafka/internal/CommitCollectorStageSpec.scala
+++ b/tests/src/test/scala/akka/kafka/internal/CommitCollectorStageSpec.scala
@@ -406,10 +406,7 @@ class CommitCollectorStageSpec(_system: ActorSystem)
private def streamProbesWithOffsetFactory(
committerSettings: CommitterSettings
- ): (TestPublisher.Probe[Committable],
- Consumer.Control,
- TestSubscriber.Probe[CommittableOffsetBatch],
- TestOffsetFactory) = {
+ ) = {
val (source, control, sink) = streamProbes(committerSettings)
val factory = TestOffsetFactory(new TestBatchCommitter(committerSettings))
(source, control, sink, factory)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org