// Generated by the gRPC C++ plugin. // FlatBuffers modified generator: native gRPC callback client API enabled when // --grpc-callback-api. source: monster_test #include "monster_test_generated.h" #include #include #include #include #include #include #include #include #include "monster_test.grpc.fb.h" namespace MyGame { namespace Example { static const char* MonsterStorage_method_names[] = { "/MyGame.Example.MonsterStorage/Store", "/MyGame.Example.MonsterStorage/Retrieve", "/MyGame.Example.MonsterStorage/GetMaxHitPoint", "/MyGame.Example.MonsterStorage/GetMinMaxHitPoints", }; std::unique_ptr MonsterStorage::NewStub( const std::shared_ptr<::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& /*options*/) { std::unique_ptr stub(new MonsterStorage::Stub(channel)); return stub; } MonsterStorage::Stub::Stub( const std::shared_ptr<::grpc::ChannelInterface>& channel) : channel_(channel), rpcmethod_Store_(MonsterStorage_method_names[0], ::grpc::internal::RpcMethod::NORMAL_RPC, channel), rpcmethod_Retrieve_(MonsterStorage_method_names[1], ::grpc::internal::RpcMethod::SERVER_STREAMING, channel), rpcmethod_GetMaxHitPoint_(MonsterStorage_method_names[2], ::grpc::internal::RpcMethod::CLIENT_STREAMING, channel), rpcmethod_GetMinMaxHitPoints_(MonsterStorage_method_names[3], ::grpc::internal::RpcMethod::BIDI_STREAMING, channel) {} ::grpc::Status MonsterStorage::Stub::Store( ::grpc::ClientContext* context, const flatbuffers::grpc::Message& request, flatbuffers::grpc::Message* response) { return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_Store_, context, request, response); } ::grpc::ClientAsyncResponseReader>* MonsterStorage::Stub::AsyncStoreRaw( ::grpc::ClientContext* context, const flatbuffers::grpc::Message& request, ::grpc::CompletionQueue* cq) { return ::grpc::internal::ClientAsyncResponseReaderFactory< flatbuffers::grpc::Message>::Create(channel_.get(), cq, rpcmethod_Store_, context, request, true); } ::grpc::ClientAsyncResponseReader>* MonsterStorage::Stub::PrepareAsyncStoreRaw( ::grpc::ClientContext* context, const flatbuffers::grpc::Message& request, ::grpc::CompletionQueue* cq) { return ::grpc::internal::ClientAsyncResponseReaderFactory< flatbuffers::grpc::Message>::Create(channel_.get(), cq, rpcmethod_Store_, context, request, false); } ::grpc::ClientReader>* MonsterStorage::Stub::RetrieveRaw( ::grpc::ClientContext* context, const flatbuffers::grpc::Message& request) { return ::grpc::internal::ClientReaderFactory< flatbuffers::grpc::Message>::Create(channel_.get(), rpcmethod_Retrieve_, context, request); } ::grpc::ClientAsyncReader>* MonsterStorage::Stub::AsyncRetrieveRaw( ::grpc::ClientContext* context, const flatbuffers::grpc::Message& request, ::grpc::CompletionQueue* cq, void* tag) { return ::grpc::internal::ClientAsyncReaderFactory< flatbuffers::grpc::Message>::Create(channel_.get(), cq, rpcmethod_Retrieve_, context, request, true, tag); } ::grpc::ClientAsyncReader>* MonsterStorage::Stub::PrepareAsyncRetrieveRaw( ::grpc::ClientContext* context, const flatbuffers::grpc::Message& request, ::grpc::CompletionQueue* cq) { return ::grpc::internal::ClientAsyncReaderFactory< flatbuffers::grpc::Message>::Create(channel_.get(), cq, rpcmethod_Retrieve_, context, request, false, nullptr); } ::grpc::ClientWriter>* MonsterStorage::Stub::GetMaxHitPointRaw( ::grpc::ClientContext* context, flatbuffers::grpc::Message* response) { return ::grpc::internal::ClientWriterFactory< flatbuffers::grpc::Message>::Create(channel_.get(), rpcmethod_GetMaxHitPoint_, context, response); } ::grpc::ClientAsyncWriter>* MonsterStorage::Stub::AsyncGetMaxHitPointRaw( ::grpc::ClientContext* context, flatbuffers::grpc::Message* response, ::grpc::CompletionQueue* cq, void* tag) { return ::grpc::internal::ClientAsyncWriterFactory< flatbuffers::grpc::Message>::Create(channel_.get(), cq, rpcmethod_GetMaxHitPoint_, context, response, true, tag); } ::grpc::ClientAsyncWriter>* MonsterStorage::Stub::PrepareAsyncGetMaxHitPointRaw( ::grpc::ClientContext* context, flatbuffers::grpc::Message* response, ::grpc::CompletionQueue* cq) { return ::grpc::internal::ClientAsyncWriterFactory< flatbuffers::grpc::Message>::Create(channel_.get(), cq, rpcmethod_GetMaxHitPoint_, context, response, false, nullptr); } ::grpc::ClientReaderWriter, flatbuffers::grpc::Message>* MonsterStorage::Stub::GetMinMaxHitPointsRaw(::grpc::ClientContext* context) { return ::grpc::internal::ClientReaderWriterFactory< flatbuffers::grpc::Message, flatbuffers::grpc::Message>::Create(channel_.get(), rpcmethod_GetMinMaxHitPoints_, context); } ::grpc::ClientAsyncReaderWriter, flatbuffers::grpc::Message>* MonsterStorage::Stub::AsyncGetMinMaxHitPointsRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) { return ::grpc::internal::ClientAsyncReaderWriterFactory< flatbuffers::grpc::Message, flatbuffers::grpc::Message>::Create(channel_.get(), cq, rpcmethod_GetMinMaxHitPoints_, context, true, tag); } ::grpc::ClientAsyncReaderWriter, flatbuffers::grpc::Message>* MonsterStorage::Stub::PrepareAsyncGetMinMaxHitPointsRaw( ::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { return ::grpc::internal::ClientAsyncReaderWriterFactory< flatbuffers::grpc::Message, flatbuffers::grpc::Message>::Create(channel_.get(), cq, rpcmethod_GetMinMaxHitPoints_, context, false, nullptr); } MonsterStorage::Service::Service() { AddMethod(new ::grpc::internal::RpcServiceMethod( MonsterStorage_method_names[0], ::grpc::internal::RpcMethod::NORMAL_RPC, new ::grpc::internal::RpcMethodHandler< MonsterStorage::Service, flatbuffers::grpc::Message, flatbuffers::grpc::Message>( std::mem_fn(&MonsterStorage::Service::Store), this))); AddMethod(new ::grpc::internal::RpcServiceMethod( MonsterStorage_method_names[1], ::grpc::internal::RpcMethod::SERVER_STREAMING, new ::grpc::internal::ServerStreamingHandler< MonsterStorage::Service, flatbuffers::grpc::Message, flatbuffers::grpc::Message>( std::mem_fn(&MonsterStorage::Service::Retrieve), this))); AddMethod(new ::grpc::internal::RpcServiceMethod( MonsterStorage_method_names[2], ::grpc::internal::RpcMethod::CLIENT_STREAMING, new ::grpc::internal::ClientStreamingHandler< MonsterStorage::Service, flatbuffers::grpc::Message, flatbuffers::grpc::Message>( std::mem_fn(&MonsterStorage::Service::GetMaxHitPoint), this))); AddMethod(new ::grpc::internal::RpcServiceMethod( MonsterStorage_method_names[3], ::grpc::internal::RpcMethod::BIDI_STREAMING, new ::grpc::internal::BidiStreamingHandler< MonsterStorage::Service, flatbuffers::grpc::Message, flatbuffers::grpc::Message>( std::mem_fn(&MonsterStorage::Service::GetMinMaxHitPoints), this))); } MonsterStorage::Service::~Service() {} ::grpc::Status MonsterStorage::Service::Store( ::grpc::ServerContext* /*context*/, const flatbuffers::grpc::Message* /*request*/, flatbuffers::grpc::Message* /*response*/) { return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } ::grpc::Status MonsterStorage::Service::Retrieve( ::grpc::ServerContext* /*context*/, const flatbuffers::grpc::Message* /*request*/, ::grpc::ServerWriter>* /*writer*/) { return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } ::grpc::Status MonsterStorage::Service::GetMaxHitPoint( ::grpc::ServerContext* /*context*/, ::grpc::ServerReader>* /*reader*/, flatbuffers::grpc::Message* /*response*/) { return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } ::grpc::Status MonsterStorage::Service::GetMinMaxHitPoints( ::grpc::ServerContext* /*context*/, ::grpc::ServerReaderWriter< flatbuffers::grpc::Message, flatbuffers::grpc::Message>* /*stream*/) { return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } } // namespace Example } // namespace MyGame