From 760ee03bd13e9f642aa29baca70b106581cb5f06 Mon Sep 17 00:00:00 2001
From: Mark Swatosh <mark.swatosh@gmail.com>
Date: Thu, 2 Nov 2023 21:29:12 -0500
Subject: [PATCH] Adding contextualProcessor to ContextService

---
 .../enterprise/concurrent/ContextService.java | 26 ++++++++++++++++---
 1 file changed, 23 insertions(+), 3 deletions(-)

diff --git a/api/src/main/java/jakarta/enterprise/concurrent/ContextService.java b/api/src/main/java/jakarta/enterprise/concurrent/ContextService.java
index 18a3bfa2..3f3ac1b6 100644
--- a/api/src/main/java/jakarta/enterprise/concurrent/ContextService.java
+++ b/api/src/main/java/jakarta/enterprise/concurrent/ContextService.java
@@ -221,20 +221,40 @@ public interface ContextService {
    * <p>Wraps a {@link java.util.concurrent.Flow.Subscriber} with context captured from the thread that invokes
    * <code>contextualSubscriber</code>. Context is captured at the time <code>contextualSubscriber</code> is invoked.</p>
    *
-   * <p>When one of the methods of the {@link java.util.concurrent.Flow.Subscriber} interface (<code>onSubscribe</code>, <code>onNext</code>,
-   * <code>onError</code>, or <code>onComplete</code>) is invoked on the proxy instance,
+   * <p>When one of the methods of the {@link java.util.concurrent.Flow.Subscriber} interface (<code>onSubscribe</code>,
+   * <code>onNext</code>, <code>onError</code>, or <code>onComplete</code>) is invoked on the proxy instance,
    * context is first established on the thread that will run the method,
    * then the method of the provided <code>Flow.Subscriber</code> is invoked.
    * Finally, the previous context is restored on the thread, and the result of the
    * <code>Flow.Subscriber</code> is returned to the invoker.</p>
    *
-   * @param <T> the subscriber's item type
+   * @param <T> the subscribed item type
    * @param subscriber instance to contextualize
    * @return contextualized proxy instance that wraps execution of the <code>onSubscribe</code>, <code>onNext</code>,
    * <code>onError</code>, and <code>onComplete</code> methods
    * @since 3.1
    */
   public <T> Flow.Subscriber<T> contextualSubscriber(Flow.Subscriber<T> subscriber);
+  
+  /**
+   * <p>Wraps a {@link java.util.concurrent.Flow.Processor} with context captured from the thread that invokes
+   * <code>contextualProcessor</code>. Context is captured at the time <code>contextualProcessor</code> is invoked.</p>
+   *
+   * <p>When one of the methods of the {@link java.util.concurrent.Flow.Subscriber} interface (<code>onSubscribe</code>, 
+   * <code>onNext</code>, <code>onError</code>, or <code>onComplete</code>) from which {@link java.util.concurrent.Flow.Processor} 
+   * extends is invoked on the proxy instance, context is first established on the thread that will run the method,
+   * then the method of the provided <code>Flow.Processor</code> is invoked.
+   * Finally, the previous context is restored on the thread, and the result of the
+   * <code>Flow.Processor</code> is returned to the invoker.</p>
+   *
+   * @param <T> the subscribed item type
+   * @param <R> the published item type
+   * @param processor instance to contextualize
+   * @return contextualized proxy instance that wraps execution of the <code>onSubscribe</code>, <code>onNext</code>,
+   * <code>onError</code>, and <code>onComplete</code> methods
+   * @since 3.1
+   */
+  public <T,R> Flow.Processor<T,R> contextualProcessor(Flow.Processor<T,R> processor);
 
   /**
    * Creates a new contextual object proxy for the input object instance.