Free cookie consent management tool by TermsFeed Policy Generator

source: branches/ExportSymbolicDataAnalysisSolutions/HeuristicLab.ExtLibs/HeuristicLab.ProtobufCS/2.4.1/ProtobufCS/src/ProtocolBuffers/RpcUtil.cs @ 9510

Last change on this file since 9510 was 8295, checked in by abeham, 12 years ago

#1897:

  • Removed protocol buffers 0.9.1
  • Added protocol buffers 2.4.1
  • Updated proto processing command
File size: 3.5 KB
Line 
1#region Copyright notice and license
2
3// Protocol Buffers - Google's data interchange format
4// Copyright 2008 Google Inc.  All rights reserved.
5// http://github.com/jskeet/dotnet-protobufs/
6// Original C++/Java/Python code:
7// http://code.google.com/p/protobuf/
8//
9// Redistribution and use in source and binary forms, with or without
10// modification, are permitted provided that the following conditions are
11// met:
12//
13//     * Redistributions of source code must retain the above copyright
14// notice, this list of conditions and the following disclaimer.
15//     * Redistributions in binary form must reproduce the above
16// copyright notice, this list of conditions and the following disclaimer
17// in the documentation and/or other materials provided with the
18// distribution.
19//     * Neither the name of Google Inc. nor the names of its
20// contributors may be used to endorse or promote products derived from
21// this software without specific prior written permission.
22//
23// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
24// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
25// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
26// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
27// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
28// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
29// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
30// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
31// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
32// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
33// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
34
35#endregion
36
37using System;
38
39namespace Google.ProtocolBuffers
40{
41    /// <summary>
42    /// Grab-bag of utility functions useful when dealing with RPCs.
43    /// </summary>
44    public static class RpcUtil
45    {
46        /// <summary>
47        /// Converts an Action[IMessage] to an Action[T].
48        /// </summary>
49        public static Action<T> SpecializeCallback<T>(Action<IMessage> action)
50            where T : IMessage<T>
51        {
52            return message => action(message);
53        }
54
55        /// <summary>
56        /// Converts an Action[T] to an Action[IMessage].
57        /// The generalized action will accept any message object which has
58        /// the same descriptor, and will convert it to the correct class
59        /// before calling the original action. However, if the generalized
60        /// callback is given a message with a different descriptor, an
61        /// exception will be thrown.
62        /// </summary>
63        public static Action<IMessage> GeneralizeCallback<TMessage, TBuilder>(Action<TMessage> action,
64                                                                              TMessage defaultInstance)
65            where TMessage : class, IMessage<TMessage, TBuilder>
66            where TBuilder : IBuilder<TMessage, TBuilder>
67        {
68            return message =>
69                       {
70                           TMessage castMessage = message as TMessage;
71                           if (castMessage == null)
72                           {
73                               castMessage = defaultInstance.CreateBuilderForType().MergeFrom(message).Build();
74                           }
75                           action(castMessage);
76                       };
77        }
78    }
79}
Note: See TracBrowser for help on using the repository browser.