Skip to content

Commit e67e88b

Browse files
committed
Merge branch 'develop' into feature/reactor34
* develop: [agent.java] reactor-core library version up # Conflicts: # scouter.agent.java/src/main/java/reactor/core/publisher/ScouterOptimizableOperatorProxy.java # scouter.agent.java/src/main/java/scouter/xtra/reactive/ReactiveSupport.java # scouter.agent.java/src/main/java/scouter/xtra/reactive/ReactiveSupportWithCoroutine.java
2 parents 2b92f0a + 2a595d7 commit e67e88b

File tree

1 file changed

+1
-6
lines changed

1 file changed

+1
-6
lines changed

scouter.agent.java/src/main/java/scouter/xtra/reactive/ReactiveSupportWithCoroutine.java

+1-6
Original file line numberDiff line numberDiff line change
@@ -90,12 +90,7 @@ public Context apply(Context context) {
9090
};
9191

9292
monoChain = (Mono<?>) subscriberContextMethod.invoke(mono, func);
93-
return monoChain.subscriberContext(new Function<Context, Context>() {
94-
@Override
95-
public Context apply(Context context) {
96-
return context.put(TraceContext.class, traceContext);
97-
}
98-
}).doOnSuccess(new Consumer<Object>() {
93+
return monoChain.doOnSuccess(new Consumer<Object>() {
9994
@Override
10095
public void accept(Object o) {
10196
TraceMain.endHttpService(new TraceMain.Stat(traceContext), null);

0 commit comments

Comments
 (0)