Merge pull request #30535 from ygree/context-propagation-annotation
Mark ContextPropagation with InternalStableApi
This commit is contained in:
commit
fedd8a7b1d
1 changed files with 4 additions and 4 deletions
|
|
@ -4,12 +4,12 @@
|
||||||
|
|
||||||
package akka.stream.impl
|
package akka.stream.impl
|
||||||
|
|
||||||
import akka.annotation.InternalApi
|
import akka.annotation.InternalStableApi
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* INTERNAL API
|
* INTERNAL API
|
||||||
*/
|
*/
|
||||||
@InternalApi trait ContextPropagation {
|
@InternalStableApi trait ContextPropagation {
|
||||||
def suspendContext(): Unit
|
def suspendContext(): Unit
|
||||||
def resumeContext(): Unit
|
def resumeContext(): Unit
|
||||||
def currentContext(): AnyRef
|
def currentContext(): AnyRef
|
||||||
|
|
@ -19,12 +19,12 @@ import akka.annotation.InternalApi
|
||||||
/**
|
/**
|
||||||
* INTERNAL API
|
* INTERNAL API
|
||||||
*/
|
*/
|
||||||
@InternalApi object ContextPropagation {
|
@InternalStableApi object ContextPropagation {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* INTERNAL API
|
* INTERNAL API
|
||||||
*/
|
*/
|
||||||
@InternalApi def apply(): ContextPropagation = new ContextPropagationImpl
|
@InternalStableApi def apply(): ContextPropagation = new ContextPropagationImpl
|
||||||
}
|
}
|
||||||
|
|
||||||
private[akka] final class ContextPropagationImpl extends ContextPropagation {
|
private[akka] final class ContextPropagationImpl extends ContextPropagation {
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue