Skip to content

Commit 1f89e94

Browse files
committed
Fix copy-paste error
1 parent acfe871 commit 1f89e94

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

driver-reactive-streams/src/main/com/mongodb/reactivestreams/client/internal/gridfs/GridFSUploadPublisherImpl.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,6 @@
5050
import static com.mongodb.reactivestreams.client.internal.TimeoutHelper.collectionWithTimeoutDeferred;
5151
import static java.time.Duration.ofMillis;
5252
import static java.util.concurrent.TimeUnit.MILLISECONDS;
53-
import static java.util.concurrent.TimeUnit.NANOSECONDS;
5453

5554

5655
/**
@@ -266,7 +265,7 @@ private Mono<Long> createSaveChunksMono(final AtomicBoolean terminated, @Nullabl
266265
* @return Mono that emits a {@link MongoOperationTimeoutException}.
267266
*/
268267
private static Mono<MongoOperationTimeoutException> createMonoTimer(final @Nullable Timeout timeout) {
269-
return Timeout.nullAsInfinite(timeout).call(NANOSECONDS,
268+
return Timeout.nullAsInfinite(timeout).call(MILLISECONDS,
270269
() -> Mono.never(),
271270
(ms) -> Mono.delay(ofMillis(ms)).then(createTimeoutMonoError()),
272271
() -> createTimeoutMonoError());

0 commit comments

Comments
 (0)