1 files changed, 2 insertions, 4 deletions

diff --git a/common/commandprocessor.h b/common/commandprocessor.h
index 75ae37a..d00cf43 100644
--- a/common/commandprocessor.h
+++ b/common/commandprocessor.h
@@ -42,7 +42,6 @@ namespace Sink {
 class CommandProcessor : public QObject
 {
     Q_OBJECT
-    typedef std::function<KAsync::Job<void>(void const *, size_t)> FlushFunction;
     SINK_DEBUG_AREA("commandprocessor")
 
 public:
@@ -50,8 +49,6 @@ public:
 
     void setOldestUsedRevision(qint64 revision);
 
-    void setFlushCommand(const FlushFunction &f);
-
     void setInspector(const QSharedPointer<Inspector> &inspector);
     void setSynchronizer(const QSharedPointer<Synchronizer> &synchronizer);
 
@@ -71,13 +68,14 @@ private slots:
     KAsync::Job<void> processPipeline();
 
 private:
+    KAsync::Job<void> flush(void const *command, size_t size);
+
     Sink::Pipeline *mPipeline;
     // Ordered by priority
     QList<MessageQueue *> mCommandQueues;
     bool mProcessingLock;
     // The lowest revision we no longer need
     qint64 mLowerBoundRevision;
-    FlushFunction mFlush;
     QSharedPointer<Synchronizer> mSynchronizer;
     QSharedPointer<Inspector> mInspector;
 };