Commit graph

12 commits

Author SHA1 Message Date
Endre Sándor Varga
18843de175 =str: Make TCP fusable (first attempts) 2015-11-30 13:38:32 +01:00
Viktor Klang
bbb942d44e !str - 18608 - Moves the a.s.io.Timeouts functionality into Source/Flow/BidiFlow 2015-11-02 11:35:29 +01:00
Roland Kuhn
556012b7ee !str,htc replace and remove OneBoundedInterpreter
main work by @drewhk with contributions from @2m and @rkuhn

This work uncovered many well-hidden bugs in existing Stages, in
particular StatefulStage. These were hidden by the behavior of
OneBoundedInterpreter that normally behaves more orderly than it
guarantees in general, especially with respect to the timeliness of
delivery of upstream termination signals; the bugs were then that
internal state was not flushed when onComplete arrived “too early”.
2015-11-01 14:53:52 +01:00
Konrad Malawski
2c2228c241 =str #16597 initial steps with idleTimeout 2015-10-27 13:55:18 -07:00
kukido
f858881b2e =doc #17329 Spelling normalization, typos fixed. 2015-09-28 22:45:38 -07:00
Endre Sándor Varga
b5a813f766 Other minor improvements 2015-07-09 11:49:32 +02:00
Viktor Klang
2725bfc044 =str - Various internal Akka Stream improvements
* Gives Inlets and Outlets a `carbonCopy` method and switches to allocate them via `apply`
* Removes 4 Array allocations per FanIn and uses a bitmasked array instead
* Makes the FlattenStrategy.concat instance a singleton
2015-06-30 11:45:50 +02:00
Endre Sándor Varga
7879a5521b Rename FlowMaterializer to Materializer 2015-06-23 18:47:28 +02:00
Endre Sándor Varga
dc7269e620 Rename OperationAttributes to Attributes 2015-06-23 18:45:04 +02:00
Endre Sándor Varga
1c6b49b1aa +str #16889: Configurable TCP close modes 2015-06-19 16:27:03 +02:00
Endre Sándor Varga
f4c83771bb !str #17393: Make stream-tests pass with serialize-messages=on 2015-06-02 12:32:27 +02:00
Patrik Nordwall
1595a8a911 !str #17031 Rename StreamTcp to Tcp 2015-04-24 14:13:54 +02:00
Renamed from akka-stream/src/main/scala/akka/stream/scaladsl/StreamTcp.scala (Browse further)