Package net.officefloor.tutorial.cosmosasyncdbhttpserver

Class CosmosAsyncDbLogic

java.lang.Object

net.officefloor.tutorial.cosmosasyncdbhttpserver.CosmosAsyncDbLogic

public class CosmosAsyncDbLogic
extends java.lang.Object

CosmosDatabase logic.

Author:

Daniel Sagenschneider

Constructor Summary

Constructors

Constructor	Description
CosmosAsyncDbLogic()

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<Post>	retrieveAllPosts(CosmosAsyncEntities entities, ObjectResponse<Post[]> response)
reactor.core.publisher.Mono<Post>	retrievePost(java.lang.String identifier, CosmosAsyncEntities entities)
reactor.core.publisher.Mono<Post>	savePost(Post post, CosmosAsyncEntities entities)
void	sendPost(Post post, ObjectResponse<Post> response)
void	sendPosts(Post[] posts, ObjectResponse<Post[]> response)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CosmosAsyncDbLogic

public CosmosAsyncDbLogic()

Method Detail

savePost

public reactor.core.publisher.Mono<Post> savePost(Post post,
                                                  CosmosAsyncEntities entities)

retrievePost

public reactor.core.publisher.Mono<Post> retrievePost(@HttpPathParameter("id")
                                                      java.lang.String identifier,
                                                      CosmosAsyncEntities entities)

sendPost

public void sendPost(@Parameter
                     Post post,
                     ObjectResponse<Post> response)

retrieveAllPosts

public reactor.core.publisher.Flux<Post> retrieveAllPosts(CosmosAsyncEntities entities,
                                                          ObjectResponse<Post[]> response)

sendPosts

public void sendPosts(@Parameter
                      Post[] posts,
                      ObjectResponse<Post[]> response)