[incubator-pekko-connectors] branch main updated: remove code copied from gist (#198)

[fa...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-connectors.git


The following commit(s) were added to refs/heads/main by this push:
     new aa60960fb remove code copied from gist (#198)
aa60960fb is described below

commit aa60960fbc1dfbe170ae86de1d20a7eb0f253394
Author: PJ Fanning <pj...@users.noreply.github.com>
AuthorDate: Sat Jul 22 12:14:46 2023 +0100

    remove code copied from gist (#198)
---
 .../org/apache/pekko/stream/connectors/ftp/BaseSpec.scala   | 13 +------------
 1 file changed, 1 insertion(+), 12 deletions(-)

diff --git a/ftp/src/test/scala/org/apache/pekko/stream/connectors/ftp/BaseSpec.scala b/ftp/src/test/scala/org/apache/pekko/stream/connectors/ftp/BaseSpec.scala
index 7dad2da60..966cf066c 100644
--- a/ftp/src/test/scala/org/apache/pekko/stream/connectors/ftp/BaseSpec.scala
+++ b/ftp/src/test/scala/org/apache/pekko/stream/connectors/ftp/BaseSpec.scala
@@ -21,7 +21,7 @@ import pekko.stream.scaladsl.{ Sink, Source }
 import pekko.testkit.TestKit
 import pekko.util.ByteString
 import org.scalatest.concurrent.{ IntegrationPatience, ScalaFutures }
-import org.scalatest.{ Args, BeforeAndAfter, BeforeAndAfterAll, Inside, Status, TestSuite, TestSuiteMixin }
+import org.scalatest.{ BeforeAndAfter, BeforeAndAfterAll, Inside, TestSuite, TestSuiteMixin }
 
 import scala.concurrent.Future
 import org.scalatest.matchers.should.Matchers
@@ -73,15 +73,4 @@ trait BaseSpec
     TestKit.shutdownActorSystem(getSystem, verifySystemShutdown = true)
     super.afterAll()
   }
-
-  // Allows to run tests n times in a row with a command line argument, useful for debugging sporadic failures
-  // e.g. ftp/testOnly *.FtpsStageSpec -- -Dtimes=20
-  // https://gist.github.com/dwickern/6ba9c5c505d2325d3737ace059302922
-  override abstract protected def runTest(testName: String, args: Args): Status = {
-    def run0(times: Int): Status = {
-      val status = super.runTest(testName, args)
-      if (times <= 1) status else status.thenRun(run0(times - 1))
-    }
-    run0(args.configMap.getWithDefault("times", "1").toInt)
-  }
 }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org