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

Merge pull request #30514 from ygree/context-propagation-improvement

Browse source 
ContextPropagation enhancement
This commit is contained in:
Yury Gribkov 2021-08-11 12:31:15 -04:00 • committed by GitHub
commit c1228ce8b3
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
3 changed files with 9 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

0
akka-stream/src/main/mima-filters/2.6.11.backwards.excludes/pr-29086-rename-grouped.excludes → akka-stream/src/main/mima-filters/2.6.12.backwards.excludes/pr-29086-rename-grouped.excludes
View file

3
akka-stream/src/main/mima-filters/2.6.16.backwards.excludes/context-propagation.backwards.excludes Normal file
View file

@ -0,0 +1,3 @@
# internal
ProblemFilters.exclude[ReversedMissingMethodProblem]("akka.stream.impl.ContextPropagation.currentContext")
ProblemFilters.exclude[ReversedMissingMethodProblem]("akka.stream.impl.ContextPropagation.resumeContext")

8
akka-stream/src/main/scala/akka/stream/impl/ContextPropagation.scala
View file

@ -9,15 +9,17 @@ import akka.annotation.InternalApi
/** /**
* INTERNAL API * INTERNAL API
*/ */
@InternalApi private[akka] trait ContextPropagation { @InternalApi trait ContextPropagation {
def suspendContext(): Unit def suspendContext(): Unit
def resumeContext(): Unit def resumeContext(): Unit
def currentContext(): AnyRef
def resumeContext(context: AnyRef): Unit
} }
/** /**
* INTERNAL API * INTERNAL API
*/ */
@InternalApi private[akka] object ContextPropagation { @InternalApi object ContextPropagation {
/** /**
* INTERNAL API * INTERNAL API
@ -28,4 +30,6 @@ import akka.annotation.InternalApi
private[akka] final class ContextPropagationImpl extends ContextPropagation { private[akka] final class ContextPropagationImpl extends ContextPropagation {
def suspendContext(): Unit = () def suspendContext(): Unit = ()
def resumeContext(): Unit = () def resumeContext(): Unit = ()
def currentContext(): AnyRef = null
def resumeContext(context: AnyRef): Unit = ()
} }