(incubator-pekko-connectors) branch main updated: remove ActorMaterializer (#273)

[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 a6dd0ee16 remove ActorMaterializer (#273)
a6dd0ee16 is described below

commit a6dd0ee164d8d86b12c547c771ffa17983c867fe
Author: PJ Fanning <pj...@users.noreply.github.com>
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: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org