useI grab the underlying actor materializer (the driver client instance exposes it).
Flow[A, B, M] => F[(M, Pipe[F, A, B])]- This is already the case except that the
Mis at the end of the signature
Flow[A, B, Future[M]] => F[(F[M], Pipe[F, A, B])]- Do you mean that AkkaStreams also has a case where it is
Future[M]for a Flow? I also don't think you can have F[M] in there since as far as I understand, you need to execute the Pipe first before F[M] can be materialized.
Mis why I got confused