| 39 | |
| 40 | public: |
| 41 | Decoder(Invoker& invoker, const char* name) : poolBuffers(invoker.poolBuffers), _name(name), _pThread(NULL), _poolThreads(invoker.poolThreads), _pDecoding(new Decoding(invoker, name)), |
| 42 | onDecoding([this](Exception& ex, UInt8* data, UInt32 size) { return decoding(ex, data, size); }) { |
| 43 | |
| 44 | _pDecoding->OnDecodedEnd::subscribe(*this); |
| 45 | _pDecoding->Events::template OnDecoded<DecodedType>::subscribe(*this); |
| 46 | _pDecoding->Events::OnDecoding::subscribe(onDecoding); |
| 47 | } |
| 48 | |
| 49 | virtual ~Decoder() { |
| 50 | _pDecoding->Events::OnDecoding::unsubscribe(onDecoding); |
nothing calls this directly
no outgoing calls
no test coverage detected