Details
-
Sub-task
-
Status: Open
-
Major
-
Resolution: Unresolved
-
0.8.1
-
None
-
None
Description
akka-streams requires the ability to access both upstream and downstream processors. For upstream akka-streams will pull - we need to emulate something similar
It depends on the type of GraphStage in akka-streams. Upstreams could halt along batch boundaries. Downstreams could cache. Here are some GraphStage examples:
Concat[T]
Interleave[T]
MergeSorted[T: Ordering]