1 package kotlinx.coroutines.reactive 2 3 import kotlinx.coroutines.InternalCoroutinesApi 4 import org.reactivestreams.Publisher 5 import kotlin.coroutines.CoroutineContext 6 7 /** @suppress */ 8 @InternalCoroutinesApi 9 public interface ContextInjector { 10 /** 11 * Injects `ReactorContext` element from the given context into the `SubscriberContext` of the publisher. 12 * This API used as an indirection layer between `reactive` and `reactor` modules. 13 */ injectCoroutineContextnull14 public fun <T> injectCoroutineContext(publisher: Publisher<T>, coroutineContext: CoroutineContext): Publisher<T> 15 }