raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Fix compilation error GraphMergePrioritizedNSpec Scala 2.12 (#31286)

Browse source 
* immutable.Seq
This commit is contained in:
Patrik Nordwall 2022-03-26 14:48:09 +01:00 • committed by GitHub
parent 83c211b84f
commit 8b42165cf1
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphMergePrioritizedNSpec.scala
View file

@ -152,10 +152,10 @@ class GraphMergePrioritizedNSpec extends StreamSpec {
val source2 = Source.fromIterator[Int](() => Iterator.empty).addAttributes(myAttributes2) val source2 = Source.fromIterator[Int](() => Iterator.empty).addAttributes(myAttributes2)
val source3: Source[Int, NotUsed] = Source.fromIterator[Int](() => Iterator.empty).addAttributes(myAttributes3) val source3: Source[Int, NotUsed] = Source.fromIterator[Int](() => Iterator.empty).addAttributes(myAttributes3)
val sourcesAndPriorities = Seq( val sourcesAndPriorities = List(
(source1, source1.getAttributes.get[MyPriority](defaultPriority).priority), (source1, source1.getAttributes.get[MyPriority](defaultPriority).priority),
(source2, source2.getAttributes.get[MyPriority](defaultPriority).priority), (source2, source2.getAttributes.get[MyPriority](defaultPriority).priority),
(source3, source3.getAttributes.get[MyPriority](defaultPriority).priority)); (source3, source3.getAttributes.get[MyPriority](defaultPriority).priority))
val probe = TestSubscriber.manualProbe[Int]() val probe = TestSubscriber.manualProbe[Int]()
@ -163,7 +163,7 @@ class GraphMergePrioritizedNSpec extends StreamSpec {
val subscription = probe.expectSubscription() val subscription = probe.expectSubscription()
var collected = Seq.empty[Int] var collected = Vector.empty[Int]
for (_ <- 1 to elementCount) { for (_ <- 1 to elementCount) {
subscription.request(1) subscription.request(1)
collected :+= probe.expectNext() collected :+= probe.expectNext()