log_stream_reactor.hpp

#pragma once
 
#include <on_prem/log/log_buffer.hpp>
#include <smartspectra/cpp/physiology_service.grpc.pb.h>
#include <grpcpp/grpcpp.h>
#include "reactor_with_wait_until_done.hpp"
 
namespace presage::smartspectra::grpc_bindings {
 
class LogStreamReactor : public ReactorWithWaitUntilDone<grpc::ServerWriteReactor<presage::smartspectra::LogEntry>> {
public:
    explicit LogStreamReactor(LogBuffer& buffer);
 
    void OnWriteDone(bool ok) override;
 
private:
    LogBuffer& buffer;
    ::presage::smartspectra::LogEntry log_entry;
};
 
} // namespace presage::smartspectra::grpc_bindings