Index: Source/modules/fetch/DataConsumerTee.cpp |
diff --git a/Source/modules/fetch/DataConsumerTee.cpp b/Source/modules/fetch/DataConsumerTee.cpp |
index af7d950a17fbc90a88dec6b9fe47428a495a5c05..857c8551b318f9eb00ada5b39bc97ca7dddd8239 100644 |
--- a/Source/modules/fetch/DataConsumerTee.cpp |
+++ b/Source/modules/fetch/DataConsumerTee.cpp |
@@ -184,7 +184,7 @@ public: |
} |
ASSERT(m_readerThread); |
if (!m_readerThread->isCurrentThread()) { |
- m_readerThread->postTask(FROM_HERE, new Task(threadSafeBind(&DestinationContext::notify, this))); |
+ m_readerThread->taskRunner()->postTask(FROM_HERE, new Task(threadSafeBind(&DestinationContext::notify, this))); |
return; |
} |
} |
@@ -271,7 +271,7 @@ public: |
// We need to use threadSafeBind here to retain the context. Note |
// |context()| return value is of type DestinationContext*, not |
// PassRefPtr<DestinationContext>. |
- Platform::current()->currentThread()->postTask(FROM_HERE, new Task(threadSafeBind(&DestinationContext::notify, context()))); |
+ Platform::current()->currentThread()->taskRunner()->postTask(FROM_HERE, new Task(threadSafeBind(&DestinationContext::notify, context()))); |
} |
} |
~DestinationReader() override |