Closed eed3si9n closed 7 years ago
This adds support for stream processing using Reactive Streams. To abstract over the capabilities, it adds Stream, which for AHC wraps low-level publisher of ByteBuffers, but for Akka HTTP it wraps Source.
This adds support for stream processing using Reactive Streams. To abstract over the capabilities, it adds Stream, which for AHC wraps low-level publisher of ByteBuffers, but for Akka HTTP it wraps Source.