Propagate Context in DataBufferUtils::write(Path)

This commit makes sure that the Reactor context is propagated in
DataBufferUtils::write(Path).

Closes gh-28933
See gh-27517
This commit is contained in:
Arjen Poutsma
2022-08-16 11:21:12 +02:00
parent dfc06eda7a
commit 7e7d6b9c3a
2 changed files with 23 additions and 1 deletions

View File

@@ -366,7 +366,8 @@ public abstract class DataBufferUtils {
sink.onDispose(() -> closeChannel(channel));
write(source, channel).subscribe(DataBufferUtils::release,
sink::error,
sink::success);
sink::success,
Context.of(sink.contextView()));
}
catch (IOException ex) {
sink.error(ex);