Graph#Shape needs uncheckedVariance in 2.11
This commit is contained in:
parent
fd621ebc36
commit
91a0dbe036
2 changed files with 3 additions and 2 deletions
|
|
@ -208,7 +208,7 @@ class FlowGraphDocSpec extends AkkaSpec {
|
||||||
import FanInShape.Init
|
import FanInShape.Init
|
||||||
|
|
||||||
class PriorityWorkerPoolShape2[In, Out](_init: Init[Out] = Name("PriorityWorkerPool"))
|
class PriorityWorkerPoolShape2[In, Out](_init: Init[Out] = Name("PriorityWorkerPool"))
|
||||||
extends FanInShape[Out](_init) {
|
extends FanInShape[Out](_init) {
|
||||||
protected override def construct(i: Init[Out]) = new PriorityWorkerPoolShape2(i)
|
protected override def construct(i: Init[Out]) = new PriorityWorkerPoolShape2(i)
|
||||||
|
|
||||||
val jobsIn = newInlet[In]("jobsIn")
|
val jobsIn = newInlet[In]("jobsIn")
|
||||||
|
|
|
||||||
|
|
@ -4,12 +4,13 @@
|
||||||
package akka.stream
|
package akka.stream
|
||||||
|
|
||||||
import akka.stream.impl.StreamLayout
|
import akka.stream.impl.StreamLayout
|
||||||
|
import scala.annotation.unchecked.uncheckedVariance
|
||||||
|
|
||||||
trait Graph[+S <: Shape, +M] {
|
trait Graph[+S <: Shape, +M] {
|
||||||
/**
|
/**
|
||||||
* Type-level accessor for the shape parameter of this graph.
|
* Type-level accessor for the shape parameter of this graph.
|
||||||
*/
|
*/
|
||||||
type Shape = S
|
type Shape = S @uncheckedVariance
|
||||||
/**
|
/**
|
||||||
* The shape of a graph is all that is externally visible: its inlets and outlets.
|
* The shape of a graph is all that is externally visible: its inlets and outlets.
|
||||||
*/
|
*/
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue