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 a6dd0ee16 remove ActorMaterializer (#273)
a6dd0ee16 is described below
commit a6dd0ee164d8d86b12c547c771ffa17983c867fe
Author: PJ Fanning <[email protected]>
AuthorDate: Mon Oct 30 12:31:12 2023 +0000
remove ActorMaterializer (#273)
---
.../org/apache/pekko/stream/connectors/csv/scaladsl/CsvBench.scala | 3 ---
1 file changed, 3 deletions(-)
diff --git
a/csv-bench/src/main/scala/org/apache/pekko/stream/connectors/csv/scaladsl/CsvBench.scala
b/csv-bench/src/main/scala/org/apache/pekko/stream/connectors/csv/scaladsl/CsvBench.scala
index 25bcc4fb9..b26b0b9c8 100644
---
a/csv-bench/src/main/scala/org/apache/pekko/stream/connectors/csv/scaladsl/CsvBench.scala
+++
b/csv-bench/src/main/scala/org/apache/pekko/stream/connectors/csv/scaladsl/CsvBench.scala
@@ -8,7 +8,6 @@ import java.util.concurrent.TimeUnit
import org.apache.pekko
import pekko.NotUsed
import pekko.actor.ActorSystem
-import pekko.stream.ActorMaterializer
import pekko.stream.scaladsl.Source
import pekko.util.ByteString
import org.openjdk.jmh.annotations._
@@ -51,7 +50,6 @@ class CsvBench {
implicit val system: ActorSystem = ActorSystem()
implicit val executionContext: ExecutionContext = system.dispatcher
- implicit val mat: ActorMaterializer = ActorMaterializer()
/**
* Size of [[ByteString]] chunks in bytes.
@@ -85,7 +83,6 @@ class CsvBench {
@TearDown
def tearDown(): Unit = {
- mat.shutdown()
system.terminate()
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
