richardimaoka / resources Goto Github PK

type T = ...
type M = ...
val source: Source[T, M] = ...
val sink: Sink[T, M]
val runnableGraph = source.toMat(sink)(Keep.Left) //Keep.LeftはSource側のmat valueをとってSinkがわのmat valueを捨てる
val materalizedValue = runnableGraph.run()

  /**
   * Creates a `Source` that is materialized as a [[org.reactivestreams.Subscriber]]
   */
  def asSubscriber[T]: Source[T, Subscriber[T]] =
    fromGraph(new SubscriberSource[T](DefaultAttributes.subscriberSource, shape("SubscriberSource")))

val runnableGraph = Source.asSubscriber[T].toMat(sink, Keep.Left)
val subscriber = runnableGraph.run()

val runnableGraph: RunnableGraph[Subscriber, Publisher] = 
  Source.asSubscriber[Mat2]
      .toMat(Sink.asPublisher[Mat2](fanout = false))(Keep.both)

val matValue: (Subscriber[T], Publisher[T]) = runnableGraph.run()

.mapMaterializedValue {
        case (sub, pub) ⇒ (Sink.fromSubscriber(sub), Source.fromPublisher(pub))
      }