Adjust adapter to the latest changes in core etl library

Author: norberttech

composer.lock

@@ -17,6 +17,7 @@
 use Flow\ETL\DSL\Entry;
 use Flow\ETL\DSL\Transform;
 use Flow\ETL\Extractor\ProcessExtractor;
+use Flow\ETL\FlowContext;
 use Flow\ETL\Pipeline\Pipes;
 use Flow\ETL\Row;
 use Flow\ETL\Rows;
@@ -33,7 +34,7 @@ public function test_start_tcp_server() : void
         $cacheId = \uniqid('cache_id');
 
         $server->initialize(new ServerProtocol(
-            Config::builder()->cache($cache)->build(),
+            new FlowContext(Config::builder()->cache($cache)->build()),
             $cacheId,
             $pool = Pool::generate(1),
             new ProcessExtractor(
@@ -70,7 +71,7 @@ public function test_start_unix_domain_socket_server() : void
         $cacheId = \uniqid('cache_id');
 
         $server->initialize(new ServerProtocol(
-            Config::builder()->cache($cache)->build(),
+            new FlowContext(Config::builder()->cache($cache)->build()),
             $cacheId,
             $pool = Pool::generate(1),
             new ProcessExtractor(

tests/Flow/ETL/Async/Tests/Integration/Server/SocketServerClientTest.php

@@ -11,6 +11,7 @@
 use Flow\ETL\Exception\InvalidArgumentException;
 use Flow\ETL\Exception\RuntimeException;
 use Flow\ETL\Extractor\ProcessExtractor;
+use Flow\ETL\FlowContext;
 use Flow\ETL\Pipeline\Pipes;
 use PHPUnit\Framework\TestCase;
 use Psr\Log\NullLogger;
@@ -42,15 +43,15 @@ public function test_initialize_server_twice() : void
         $server = SocketServer::tcp(6541, $logger = new NullLogger());
 
         $server->initialize(new ServerProtocol(
-            Config::default(),
+            new FlowContext(Config::default()),
             'cache_id',
             Pool::generate(1),
             new ProcessExtractor(),
             Pipes::empty()
         ));
 
         $server->initialize(new ServerProtocol(
-            Config::default(),
+            new FlowContext(Config::default()),
             'cache_id',
             Pool::generate(1),
             new ProcessExtractor(),