Akka Stream：Outlet to FlowOps

Question

Outlet[A]をFlowOps[A, _]に持ち上げることはできますか？ inがSourceまたはFlowのいずれかであったならば、それは同じようにそのgroupedコール作業を行うには

import akka.NotUsed 
import akka.stream.Outlet 
import akka.stream.scaladsl.{FlowOps, GraphDSL, Source} 

def filter(in: Outlet[Double]) 
      (implicit b: GraphDSL.Builder[NotUsed]): Outlet[Double] = { 
    val in0: FlowOps[Double, NotUsed] = ??? 
    val res = in0.grouped(8).statefulMapConcat[Double] {() => 
    seq => seq.reverse 
    } 
    res 
    ??? : Outlet[Double] 
} 

：私はこれを持っている場合、それはありますか？

Answer 1

これはちょうどOutletが流れOPSのために使用することができ、その後、暗黙のインポートがありませんでした：

def filter(in: Outlet[Double]) 
      (implicit b: GraphDSL.Builder[NotUsed]): Outlet[Double] = { 
    import GraphDSL.Implicits._ 
    import scala.collection.immutable.{Seq => ISeq} 
    val grouped: PortOps[ISeq[Double]] = in.grouped(8) 
    val flattened: PortOps[Double] = grouped.statefulMapConcat[Double] {() => 
     seq => seq.reverse 
    } 
    flattened.outlet 
    }