equal
deleted
inserted
replaced
13 #include "QtRelationalReaderStringHadler.h" |
13 #include "QtRelationalReaderStringHadler.h" |
14 |
14 |
15 using namespace relpipe::cli; |
15 using namespace relpipe::cli; |
16 using namespace relpipe::reader; |
16 using namespace relpipe::reader; |
17 |
17 |
18 class WorkerThread : public QThread { |
18 class RelationalReaderThread : public QThread { |
19 private: |
19 private: |
20 std::shared_ptr<RelationalReader> reader; |
20 std::shared_ptr<RelationalReader> reader; |
21 public: |
21 public: |
22 |
22 |
23 // TODO: better background thread; lambda? |
23 // TODO: better background thread; lambda? |
24 |
24 |
25 WorkerThread(std::shared_ptr<RelationalReader> reader) : |
25 RelationalReaderThread(std::shared_ptr<RelationalReader> reader) : |
26 reader(reader) { |
26 reader(reader) { |
27 setTerminationEnabled(true); |
27 setTerminationEnabled(true); |
28 } |
28 } |
29 |
29 |
30 void run() { |
30 void run() { |
58 |
58 |
59 QtRelationalReaderStringHadler handler(&app, &window); |
59 QtRelationalReaderStringHadler handler(&app, &window); |
60 reader->addHandler(&handler); |
60 reader->addHandler(&handler); |
61 |
61 |
62 // Start background thread |
62 // Start background thread |
63 WorkerThread t(reader); |
63 RelationalReaderThread t(reader); |
64 t.start(); |
64 t.start(); |
65 // --- |
65 // --- |
66 |
66 |
67 // window.signal123(); |
67 // window.signal123(); |
68 |
68 |