Commit graph

32 commits

Author SHA1 Message Date
Auto Format
ce404e4f53 format source with scalafmt 2019-03-11 16:58:55 +01:00
Patrik Nordwall
5c96a5f556 replace unicode arrows
* ⇒, →, ←
* because we don't want to show them in documentation snippets and
  then it's complicated to avoid that when snippets are
  located in src/test/scala in individual modules
* dont replace object `→` in FSM.scala and PersistentFSM.scala
2019-03-11 16:58:51 +01:00
kerr
bdc90052aa Update headers from 2018 to 2019 once for all. (#26165)
* Add CopyrightHeader support for sbt-boilerplate plugin.
* Add CopyrightHeader support for `*.proto` files.
* Add regex match for both `–` and `-` for CopyrightHeader.
* Add CopyrightHeader support for sbt build files.
* Update copyright from 2018 to 2019.
2019-01-02 11:55:26 +01:00
kerr
e9fb3a020a Make use of scalafix to remove unused import. (#26019)
* =build Add scalafix to remote unused import.

* +build Add file ignore plugin for scalafix which support ignore files.
2018-12-05 08:30:21 +00:00
Carlier Guillaume
70aa175d6c Fix bug in Balance stage when some downstreams pull and close immediately and an another try to pull but wait a response indefinitely #25387 2018-07-24 17:58:42 +02:00
Martynas Mickevičius
766944a592
Expose assertAllStagesStopped 2018-06-27 10:34:32 +03:00
Hawstein
ecdaf0e530 add eagerCancel to Partition and Balance stage (#22339)
* add eagerCancel to Partition and Balance stage

* fix mima error

* rebase master and add unit test

* add java support and since to deprecated
2018-04-10 01:46:39 +09:00
Jimin Hsieh
3685ce619e Remove some of Unused import warning (#24750)
* Remove `Unused import` of `akka-actor-typed`

* Remove `Unused import` of `akka-actor-typed-tests`

* Remove `Unused import` of `akka-stream-tests`

* Remove `Unused import` of `akka-persistence`

* Remove `Unused import` of `akka-persistence-typed`

* Remove `Unused import` of `akka-cluster-typed`

* Remove `Unused import` of `akka-cluster-sharding-typed`

* Format source code
2018-03-20 12:01:15 +09:00
Konrad `ktoso` Malawski
563c7fbcf0 Issue 24594: Integration with sbt-headers and initial header population 2018-03-13 15:45:55 +01:00
Johan Andrén
a81a61ba1f Balancer should not push to a closed out #20943 2016-08-18 15:44:27 +02:00
Hawstein
39008dc58a replace AkkaSpec with StreamSpec for stream tests #21011 2016-07-28 10:43:08 +02:00
Björn Antonsson
c66ce62d63 Update to a working version of Scalariform 2016-06-02 22:12:36 +02:00
Roland Kuhn
45e97e8467 remove akka.stream.testkit.AkkaSpec, fixes #19879 2016-02-25 15:26:51 +01:00
Johan Andrén
6ad1eab8e6 Balance should also be allowed to have just one input 2016-01-21 15:06:36 +01:00
Martynas Mickevičius
e6e476d82a =str #19128 #19127 rename Source/Sink factory apply overloads 2015-12-17 11:48:30 +02:00
Roland Kuhn
f00da4daac !str #19037 rename FlowGraph to GraphDSL 2015-12-01 18:30:07 +01:00
Viktor Klang
6cfa4df800 !str - Switches Sink.publisher to use a boolean to indicate fanout rather than a number of allowed subscribers 2015-11-04 12:29:23 +01:00
Viktor Klang
f839a1f85d !str - 18808 - Removes Sink.fanoutPublisher and makes Sink.publisher specify number of subscribers
Sink.publisher now takes a max number of Subscribers and
the elasticity between concurrent Subscribers.
2015-11-04 12:29:07 +01:00
Viktor Klang
f29d7affbd !str #18692 javadsl.FlowGraph.Builder.add()
* also make factories more consistent by only offering
  FlowGraph.create()
* also remove secondary (edge-based) FlowGraph.Builder DSL
* also improve naming for conversions from Graph to
  Source/Flow/BidiFlow/Sink
2015-10-22 19:10:00 +02:00
Endre Sándor Varga
7879a5521b Rename FlowMaterializer to Materializer 2015-06-23 18:47:28 +02:00
Martynas Mickevičius
b1431313e5 =str #17176 do not check for arbitrary conditions that depends on thread scheduling 2015-04-24 13:32:16 +03:00
Martynas Mickevičius
8e2cc3e70f =str #17089 stream testkit 2015-04-24 12:25:54 +03:00
Patrik Nordwall
f930bcdda8 =str #15191 Verify that stage actors are stopped
* found one bug of too early actor stop and thereby missing cancel of upstream,
  in fan-in tests ""work with one immediately failed and one nonempty publisher"
2015-04-23 20:00:12 +02:00
Roland Kuhn
743cd98bf4 fix two wrong/flaky tests
- ordering is not preserved by shufflers in GraphOpsIntegrationSpec
- larger tolerance is needed in GraphBalanceSpec since balancing does
  not keep track of previous imbalances
- also add Source.repeat(elem)
2015-02-26 14:22:26 +01:00
Endre Sándor Varga
8d77fa8b29 !str #16902: Unify stream internal representation
also =str #16912: Fix StreamTcpSpec flakiness
2015-02-26 10:06:56 +01:00
Patrik Nordwall
cd9d503b03 !str #15851 Rename FlowMaterializer and settings
* FlowMaterializer is now the actor independent interface
* ActorFlowMaterializer is the actor based interface
* MaterializerSettings renamed to ActorFlowMaterializerSettings
* impl.ActorBasedFlowMaterializer renamed to impl.ActorFlowMaterializerImpl
* Optimizations included in ActorFlowMaterializerSettings
* Note that http is using FlowMaterializer in api, but I suspect that it
  will currently only run with a ActorFlowMaterializer
2015-01-27 19:22:22 +01:00
Patrik Nordwall
e85ba73af0 !str #16484 #16392 Remove String identifier of junctions
* descriptive name can still be defined with OperationAttributes.name
* revisit all factory methods (apply/create) and implement and document
  them in a consistent manner
2014-12-18 12:25:59 +01:00
Patrik Nordwall
601b67c8e7 !str #16455 Remove unused fanout settings 2014-12-16 15:07:41 +01:00
Viktor Klang
18067cbf8f +str - Fixes #16065 by adding an IteratorPublisher and removing SimpleCallbackPublisher
Adds an IteratorPublisher and IteratorPublisherImpl
Removes the SimpleCallbackPublisher
Switches the callback-source () => Option[T] to use a new ThunkIterator and the IteratorPublisher
Removes the use of a ControlThrowable (Stop) for signalling end since we now use Iterator
Improves a couple of streams-related tests so when they fail we get better output
2014-11-10 12:56:41 +01:00
Patrik Nordwall
65269274b1 !str #16235 Rename Sink.future to Sink.head 2014-11-07 08:07:17 +01:00
Björn Antonsson
8003332542 =str #16051 Possibility for Balance to wait for all downstream
* co-authored by @patriknw

balance-fix
2014-11-05 10:33:26 +01:00
Patrik Nordwall
7c0c618791 !str #16039 Remove old scaladsl, rename scaladsl2
* and impl2, testkit2
* keeping io2 for now
2014-10-28 14:20:19 +01:00
Renamed from akka-stream-tests/src/test/scala/akka/stream/scaladsl2/GraphBalanceSpec.scala (Browse further)