import org.springframework.data.mongodb.core.ReactiveMongoOperations; //导入依赖的package包/类
/**
 * Application runner to initialize a capped collection for {@link Event}s and insert a new {@link Event} every two
 * seconds.
 * 
 * @param operations
 * @param reactiveOperations
 * @return
 */
@Bean
ApplicationRunner onStart(MongoOperations operations, ReactiveMongoOperations reactiveOperations) {

	return args -> {

		CollectionOptions options = CollectionOptions.empty() //
				.capped() //
				.size(2048) //
				.maxDocuments(1000);

		operations.dropCollection(Event.class);
		operations.createCollection(Event.class, options);

		Flux.interval(Duration.ofSeconds(2)) //
				.map(counter -> new Event(LocalDateTime.now())) //
				.flatMap(reactiveOperations::save) //
				.log() //
				.subscribe();
	};
}
 

import org.springframework.data.mongodb.core.ReactiveMongoOperations; //导入依赖的package包/类
@Bean
public ReactiveMongoOperationsSessionRepository reactiveMongoOperationsSessionRepository(ReactiveMongoOperations operations) {
	
	ReactiveMongoOperationsSessionRepository repository = new ReactiveMongoOperationsSessionRepository(operations);

	if (this.mongoSessionConverter != null) {
		repository.setMongoSessionConverter(this.mongoSessionConverter);
	}

	if (this.maxInactiveIntervalInSeconds != null) {
		repository.setMaxInactiveIntervalInSeconds(this.maxInactiveIntervalInSeconds);
	}

	if (this.collectionName != null) {
		repository.setCollectionName(this.collectionName);
	}

	if (this.mongoOperations != null) {
		repository.setBlockingMongoOperations(this.mongoOperations);
	}
	
	return repository;
}
 

import org.springframework.data.mongodb.core.ReactiveMongoOperations; //导入依赖的package包/类
@Test
public void missingReactorSessionRepositoryBreaksAppContext() {

	this.context = new AnnotationConfigApplicationContext();
	this.context.register(BadConfig.class);

	assertThatExceptionOfType(UnsatisfiedDependencyException.class)
			.isThrownBy(this.context::refresh)
			.withMessageContaining("Error creating bean with name 'reactiveMongoOperationsSessionRepository'")
			.withMessageContaining("No qualifying bean of type '" + ReactiveMongoOperations.class.getCanonicalName());
}
 

import org.springframework.data.mongodb.core.ReactiveMongoOperations; //导入依赖的package包/类
@Bean
ReactiveMongoRepositoryFactory reactiveMongoRepositoryFactory(ReactiveMongoOperations reactiveMongoOperations) {

	ReactiveMongoRepositoryFactory factory = new ReactiveMongoRepositoryFactory(reactiveMongoOperations);
	factory.setRepositoryBaseClass(SimpleReactiveMongoRepository.class);
	factory.setBeanClassLoader(classLoader);
	factory.setBeanFactory(beanFactory);
	factory.setEvaluationContextProvider(DefaultEvaluationContextProvider.INSTANCE);

	return factory;
}
 

import org.springframework.data.mongodb.core.ReactiveMongoOperations; //导入依赖的package包/类
public ReactiveMongoOperationsSessionRepository(ReactiveMongoOperations mongoOperations) {
	this.mongoOperations = mongoOperations;
}
 

import org.springframework.data.mongodb.core.ReactiveMongoOperations; //导入依赖的package包/类
@Bean
ReactiveMongoOperations operations() {
	return mock(ReactiveMongoOperations.class);
}
 

import org.springframework.data.mongodb.core.ReactiveMongoOperations; //导入依赖的package包/类
@Bean
ReactiveMongoOperations reactiveMongoOperations() {
	return mock(ReactiveMongoOperations.class);
}