library/cpp/actors/interconnect/poller.h


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

#pragma once

#include <functional>
#include <library/cpp/actors/core/events.h>

namespace NActors {
    class TSharedDescriptor: public TThrRefBase { 
    public: 
        virtual int GetDescriptor() = 0; 
    }; 

    using TDelegate = std::function<void()>; 
    using TFDDelegate = std::function<TDelegate(const TIntrusivePtr<TSharedDescriptor>&)>; 

    class IPoller: public TThrRefBase { 
    public: 
        virtual ~IPoller() = default; 

        virtual void StartRead(const TIntrusivePtr<TSharedDescriptor>& s, TFDDelegate&& operation) = 0; 
        virtual void StartWrite(const TIntrusivePtr<TSharedDescriptor>& s, TFDDelegate&& operation) = 0; 
    }; 

}