Skip to content
Snippets Groups Projects

F async execute

Merged Timm Fitschen requested to merge f-async-execute into dev
All threads resolved!
Files
14
@@ -55,10 +55,10 @@
#include "caosdb/file_transmission/file_writer.h" // for FileWriter
#include "caosdb/handler_interface.h" // for HandlerTag, Handl...
#include <cstdint> // for uint64_t
#include <grpcpp/impl/codegen/async_stream.h> // for ClientAsyncReader
#include <grpcpp/impl/codegen/client_context.h> // for ClientContext
#include <grpcpp/impl/codegen/completion_queue.h> // for CompletionQueue
#include <grpcpp/impl/codegen/status.h> // for Status
#include <grpcpp/client_context.h> // for ClientContext
#include <grpcpp/completion_queue.h> // for CompletionQueue
#include <grpcpp/support/async_stream.h> // for ClientAsyncReader
#include <grpcpp/support/status.h> // for Status
#include <memory> // for unique_ptr
namespace caosdb::transaction {
@@ -84,7 +84,11 @@ public:
DownloadRequestHandler(DownloadRequestHandler &&) = delete;
DownloadRequestHandler &operator=(DownloadRequestHandler &&) = delete;
void Start() override { OnNext(true); }
void Start() override {
if (state_ == CallState::NewCall) {
OnNext(true);
}
}
bool OnNext(bool ok) override;
Loading