Skip to content

Ensure Sink.contextView is propagated #1450

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 10 commits into from
Aug 1, 2024
Merged

Ensure Sink.contextView is propagated #1450

Changes from 1 commit
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
30f3de9
Ensure Sink.contextView is propagated
rozza Jul 15, 2024
bce9f74
Code review updates
rozza Jul 25, 2024
12083ad
Code review explicitly set the context
rozza Jul 25, 2024
905202f
Merge branch 'master' into JAVA-5345
rozza Jul 25, 2024
96da0b8
Replace use of Mono.create in GridFSUploadPublisherImpl
rozza Jul 26, 2024
55cdbf7
Remove nested subscription from within Mono.
rozza Jul 26, 2024
57dbf6a
Pass context to cancellation mono
rozza Jul 26, 2024
2d0db20
Update context propagation in BatchCursorFlux
rozza Jul 26, 2024
38109c9
Unify ordering in Crypt.java
rozza Jul 26, 2024
cc75540
More idiomatic change of empty mono type
rozza Jul 29, 2024
File filter

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
More idiomatic change of empty mono type
  • Loading branch information
@rozza
rozza committed Jul 29, 2024
commit cc75540820f3453e6491f1e009ace3b470184446
5 changes: 1 addition & 4 deletions ...rc/main/com/mongodb/reactivestreams/client/internal/gridfs/GridFSUploadPublisherImpl.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -35,14 +35,11 @@
import org.reactivestreams.Subscriber;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import reactor.core.scheduler.Schedulers;
import reactor.util.context.ContextView;

import java.nio.ByteBuffer;
import java.util.Date;
import java.util.Map;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.function.Function;

import static com.mongodb.ReadPreference.primary;
import static com.mongodb.assertions.Assertions.notNull;
Expand Down Expand Up @@ -155,7 +152,7 @@ private Mono<Void> createCheckAndCreateIndexesMono(@Nullable final Timeout timeo
.switchIfEmpty(Mono.defer(() ->
checkAndCreateIndex(filesCollection.withReadPreference(primary()), FILES_INDEX, timeout)
.then(checkAndCreateIndex(chunksCollection.withReadPreference(primary()), CHUNKS_INDEX, timeout))
.then(Mono.fromCallable(Document::new))
.then(Mono.empty())
))
.then();
}
Expand Down