+str #16038 Create Source/Flow/Sink from partial flow graphs

Fixes #16038
    val collected = (1 to requests).map { _ =>
      subscription.request(1)
      probe.expectNext()
    }.toSet