| OLD | NEW |
| (Empty) |
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #ifndef BLIMP_HELIUM_STREAM_H_ | |
| 6 #define BLIMP_HELIUM_STREAM_H_ | |
| 7 | |
| 8 #include <memory> | |
| 9 | |
| 10 #include "base/callback.h" | |
| 11 #include "blimp/helium/result.h" | |
| 12 | |
| 13 namespace blimp { | |
| 14 namespace helium { | |
| 15 | |
| 16 class HeliumMessage; | |
| 17 | |
| 18 // Pure virtual interface for HeliumMessage-oriented transport streams. | |
| 19 // Details about how the helium::Stream is bound to the network layer are | |
| 20 // handled by subclasses of helium::Stream. | |
| 21 class Stream { | |
| 22 public: | |
| 23 using ReceiveMessageCallback = | |
| 24 base::Callback<void(std::unique_ptr<HeliumMessage>, Result)>; | |
| 25 | |
| 26 virtual ~Stream() = default; | |
| 27 | |
| 28 // Sends |helium_message| over the Stream. |callback| is invoked when the | |
| 29 // message is sent (or otherwise moved to the low-level write buffers), | |
| 30 // which signals the caller that it is clear to send another message. | |
| 31 // | |
| 32 // The caller is responsible for ensuring that only one outstanding | |
| 33 // SendMessage() call is made at a time. | |
| 34 virtual void SendMessage(std::unique_ptr<HeliumMessage> helium_message, | |
| 35 const base::Callback<void(Result)>& callback) = 0; | |
| 36 | |
| 37 // Asynchronously reads a HeliumMessage from the stream. | |
| 38 // The caller is responsible for ensuring that only one outstanding | |
| 39 // ReceiveMessage() call is made at a time. | |
| 40 // | |
| 41 // In the event that an error occurred, a null pointer will be passed instead | |
| 42 // of a HeliumMessage, with a HeliumResult describing the failure reason. | |
| 43 // The HeliumStream object is considered inactive/unusable at this point and | |
| 44 // should be discarded by its owner. | |
| 45 virtual void ReceiveMessage(const ReceiveMessageCallback& on_receive_cb) = 0; | |
| 46 }; | |
| 47 | |
| 48 } // namespace helium | |
| 49 } // namespace blimp | |
| 50 | |
| 51 #endif // BLIMP_HELIUM_STREAM_H_ | |
| OLD | NEW |