class OutboundLink {
public:
virtual ~OutboundLink() = default;
- virtual Future<void> write(Out msg) = 0;
- virtual Future<void> close() = 0;
+ virtual Future<Unit> write(Out msg) = 0;
+ virtual Future<Unit> close() = 0;
};
template <class H, class Context>
}
}
- Future<void> fireWrite(Wout msg) override {
+ Future<Unit> fireWrite(Wout msg) override {
DestructorGuard dg(this->pipeline_);
if (this->nextOut_) {
return this->nextOut_->write(std::forward<Wout>(msg));
}
}
- Future<void> fireClose() override {
+ Future<Unit> fireClose() override {
DestructorGuard dg(this->pipeline_);
if (this->nextOut_) {
return this->nextOut_->close();
}
// OutboundLink overrides
- Future<void> write(Win msg) override {
+ Future<Unit> write(Win msg) override {
DestructorGuard dg(this->pipeline_);
return this->handler_->write(this, std::forward<Win>(msg));
}
- Future<void> close() override {
+ Future<Unit> close() override {
DestructorGuard dg(this->pipeline_);
return this->handler_->close(this);
}
~OutboundContextImpl() = default;
// OutboundHandlerContext overrides
- Future<void> fireWrite(Wout msg) override {
+ Future<Unit> fireWrite(Wout msg) override {
DestructorGuard dg(this->pipeline_);
if (this->nextOut_) {
return this->nextOut_->write(std::forward<Wout>(msg));
}
}
- Future<void> fireClose() override {
+ Future<Unit> fireClose() override {
DestructorGuard dg(this->pipeline_);
if (this->nextOut_) {
return this->nextOut_->close();
}
// OutboundLink overrides
- Future<void> write(Win msg) override {
+ Future<Unit> write(Win msg) override {
DestructorGuard dg(this->pipeline_);
return this->handler_->write(this, std::forward<Win>(msg));
}
- Future<void> close() override {
+ Future<Unit> close() override {
DestructorGuard dg(this->pipeline_);
return this->handler_->close(this);
}