| OLD | NEW | 
|---|
|  | (Empty) | 
| 1 // Copyright 2015 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_NET_BLIMP_MESSAGE_MULTIPLEXER_H_ |  | 
| 6 #define BLIMP_NET_BLIMP_MESSAGE_MULTIPLEXER_H_ |  | 
| 7 |  | 
| 8 #include <memory> |  | 
| 9 |  | 
| 10 #include "base/macros.h" |  | 
| 11 #include "base/memory/weak_ptr.h" |  | 
| 12 #include "blimp/common/proto/blimp_message.pb.h" |  | 
| 13 #include "blimp/net/blimp_net_export.h" |  | 
| 14 |  | 
| 15 namespace blimp { |  | 
| 16 |  | 
| 17 class BlimpMessageProcessor; |  | 
| 18 |  | 
| 19 // Creates MessageProcessors that receive outgoing messages and put them |  | 
| 20 // onto a multiplexed message stream. |  | 
| 21 // BlimpMessageMultiplexer is created on the UI thread, and then used and |  | 
| 22 // destroyed on the IO thread. |  | 
| 23 class BLIMP_NET_EXPORT BlimpMessageMultiplexer { |  | 
| 24  public: |  | 
| 25   // |output_processor|: A pointer to the MessageProcessor that will receive the |  | 
| 26   // multiplexed message stream. |  | 
| 27   explicit BlimpMessageMultiplexer(BlimpMessageProcessor* output_processor); |  | 
| 28 |  | 
| 29   ~BlimpMessageMultiplexer(); |  | 
| 30 |  | 
| 31   // Creates a BlimpMessageProcessor object for sending messages of type |  | 
| 32   // |feature_case|. Any number of senders can be created at a time for a given |  | 
| 33   // type. |  | 
| 34   std::unique_ptr<BlimpMessageProcessor> CreateSender( |  | 
| 35       BlimpMessage::FeatureCase feature_case); |  | 
| 36 |  | 
| 37  private: |  | 
| 38   base::WeakPtrFactory<BlimpMessageProcessor> output_weak_factory_; |  | 
| 39 |  | 
| 40   DISALLOW_COPY_AND_ASSIGN(BlimpMessageMultiplexer); |  | 
| 41 }; |  | 
| 42 |  | 
| 43 }  // namespace blimp |  | 
| 44 |  | 
| 45 #endif  // BLIMP_NET_BLIMP_MESSAGE_MULTIPLEXER_H_ |  | 
| OLD | NEW | 
|---|