ServiceWorker: Use mojo's data pipe for respondWith(stream)

third_party/WebKit/public/platform/modules/serviceworker/WebServiceWorkerStreamHandle.h

Index: third_party/WebKit/public/platform/modules/serviceworker/WebServiceWorkerStreamHandle.h
diff --git a/third_party/WebKit/public/platform/modules/serviceworker/WebServiceWorkerStreamHandle.h b/third_party/WebKit/public/platform/modules/serviceworker/WebServiceWorkerStreamHandle.h
new file mode 100644
index 0000000000000000000000000000000000000000..e079e44a9887507a9246087e787dfa979fa5c92d
--- /dev/null
+++ b/third_party/WebKit/public/platform/modules/serviceworker/WebServiceWorkerStreamHandle.h
@@ -0,0 +1,43 @@
+// Copyright 2017 The Chromium Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+
+#ifndef WebServiceWorkerStreamHandle_h
+#define WebServiceWorkerStreamHandle_h
+
+#include <memory>
+
+#include "mojo/public/cpp/system/data_pipe.h"
+#include "public/platform/WebCommon.h"
+
+namespace blink {
+
+// Contains the info to send back a body to the page over Mojo's data pipe.
+class BLINK_PLATFORM_EXPORT WebServiceWorkerStreamHandle {
+ public:
+  // Listener can observe whether the data pipe is successfully closed at the
+  // end of the body or it has accidentally finished.
+  class Listener {
+   public:
+    virtual ~Listener(){};
+    virtual void OnAborted() = 0;
+    virtual void OnCompleted() = 0;
+  };
+
+  void SetListener(std::unique_ptr<Listener>);
+  mojo::ScopedDataPipeConsumerHandle DrainStreamDataPipe();
+
+#if INSIDE_BLINK
+  WebServiceWorkerStreamHandle(mojo::ScopedDataPipeConsumerHandle stream)
+      : stream_(std::move(stream)) {}
+  void Aborted();
+  void Completed();
+#endif
+
+ private:
+  mojo::ScopedDataPipeConsumerHandle stream_;
+  std::unique_ptr<Listener> listener_;
+};
+}
+
+#endif  // WebServiceWorkerStreamHandle_h