forked from msgpack/msgpack-cli
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathNonGenericEnumerableMessagePackSerializer`1.cs
More file actions
166 lines (150 loc) · 6.74 KB
/
NonGenericEnumerableMessagePackSerializer`1.cs
File metadata and controls
166 lines (150 loc) · 6.74 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
#region -- License Terms --
//
// MessagePack for CLI
//
// Copyright (C) 2015-2016 FUJIWARA, Yusuke
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
//
#endregion -- License Terms --
#if UNITY_5 || UNITY_STANDALONE || UNITY_WEBPLAYER || UNITY_WII || UNITY_IPHONE || UNITY_ANDROID || UNITY_PS3 || UNITY_XBOX360 || UNITY_FLASH || UNITY_BKACKBERRY || UNITY_WINRT
#define UNITY
#endif
using System;
using System.Collections;
using System.Linq;
using System.Runtime.Serialization;
#if FEATURE_TAP
using System.Threading;
using System.Threading.Tasks;
#endif // FEATURE_TAP
namespace MsgPack.Serialization.CollectionSerializers
{
/// <summary>
/// Provides common implementation of <see cref="NonGenericEnumerableMessagePackSerializerBase{TCollection}"/>
/// for collection types which implement <see cref="IEnumerable"/>.
/// </summary>
/// <typeparam name="TCollection">The type of the collection.</typeparam>
public abstract class NonGenericEnumerableMessagePackSerializer<TCollection> : NonGenericEnumerableMessagePackSerializerBase<TCollection>
where TCollection : IEnumerable
{
/// <summary>
/// Initializes a new instance of the <see cref="NonGenericCollectionMessagePackSerializer{TCollection}"/> class.
/// </summary>
/// <param name="ownerContext">A <see cref="SerializationContext"/> which owns this serializer.</param>
/// <param name="schema">
/// The schema for collection itself or its items for the member this instance will be used to.
/// <c>null</c> will be considered as <see cref="PolymorphismSchema.Default"/>.
/// </param>
/// <exception cref="ArgumentNullException">
/// <paramref name="ownerContext"/> is <c>null</c>.
/// </exception>
protected NonGenericEnumerableMessagePackSerializer( SerializationContext ownerContext, PolymorphismSchema schema )
: base( ownerContext, schema ) { }
/// <summary>
/// Initializes a new instance of the <see cref="NonGenericCollectionMessagePackSerializer{TCollection}"/> class.
/// </summary>
/// <param name="ownerContext">A <see cref="SerializationContext"/> which owns this serializer.</param>
/// <param name="schema">
/// The schema for collection itself or its items for the member this instance will be used to.
/// <c>null</c> will be considered as <see cref="PolymorphismSchema.Default"/>.
/// </param>
/// <param name="capabilities">A serializer calability flags represents capabilities of this instance.</param>
/// <exception cref="ArgumentNullException">
/// <paramref name="ownerContext"/> is <c>null</c>.
/// </exception>
protected NonGenericEnumerableMessagePackSerializer( SerializationContext ownerContext, PolymorphismSchema schema, SerializerCapabilities capabilities )
: base( ownerContext, schema, capabilities ) { }
/// <summary>
/// Serializes specified object with specified <see cref="Packer"/>.
/// </summary>
/// <param name="packer"><see cref="Packer"/> which packs values in <paramref name="objectTree"/>. This value will not be <c>null</c>.</param>
/// <param name="objectTree">Object to be serialized.</param>
/// <exception cref="SerializationException">
/// <typeparamref name="TCollection"/> is not serializable etc.
/// </exception>
[System.Diagnostics.CodeAnalysis.SuppressMessage( "Microsoft.Design", "CA1062:ValidateArgumentsOfPublicMethods", MessageId = "0", Justification = "Validated by caller in base class" )]
protected internal override void PackToCore( Packer packer, TCollection objectTree )
{
ICollection asICollection;
if ( ( asICollection = objectTree as ICollection ) == null )
{
asICollection = objectTree.Cast<object>().ToArray();
}
packer.PackArrayHeader( asICollection.Count );
foreach ( var item in asICollection )
{
this.ItemSerializer.PackTo( packer, item );
}
}
#if FEATURE_TAP
/// <summary>
/// Serializes specified object with specified <see cref="Packer"/> asynchronously.
/// </summary>
/// <param name="packer"><see cref="Packer"/> which packs values in <paramref name="objectTree"/>. This value will not be <c>null</c>.</param>
/// <param name="objectTree">Object to be serialized.</param>
/// <param name="cancellationToken">The token to monitor for cancellation requests. The default value is <see cref="CancellationToken.None"/>.</param>
/// <returns>
/// A <see cref="Task"/> that represents the asynchronous operation.
/// </returns>
/// <exception cref="System.Runtime.Serialization.SerializationException">
/// Failed to serialize object.
/// </exception>
/// <exception cref="NotSupportedException">
/// <typeparamref name="TCollection"/> is not serializable even if it can be deserialized.
/// </exception>
/// <seealso cref="P:Capabilities"/>
protected internal override async Task PackToAsyncCore( Packer packer, TCollection objectTree, CancellationToken cancellationToken )
{
ICollection asICollection;
if ( ( asICollection = objectTree as ICollection ) == null )
{
asICollection = objectTree.Cast<object>().ToArray();
}
await packer.PackArrayHeaderAsync( asICollection.Count, cancellationToken ).ConfigureAwait( false );
foreach ( var item in asICollection )
{
await this.ItemSerializer.PackToAsync( packer, item, cancellationToken ).ConfigureAwait( false );
}
}
#endif // FEATURE_TAP
}
#if UNITY
#warning TODO: Remove if possible for maintenancibility.
internal abstract class UnityNonGenericEnumerableMessagePackSerializer : UnityNonGenericEnumerableMessagePackSerializerBase
{
protected UnityNonGenericEnumerableMessagePackSerializer( SerializationContext ownerContext, Type targetType, PolymorphismSchema schema, SerializerCapabilities capabilities )
: base( ownerContext, targetType, schema, capabilities ) { }
protected internal override void PackToCore( Packer packer, object objectTree )
{
var asEnumerable = objectTree as IEnumerable;
int count;
ICollection asCollection;
if ( ( asCollection = objectTree as ICollection ) == null )
{
// ReSharper disable once AssignNullToNotNullAttribute
count = asEnumerable.OfType<object>().ToArray().Length;
}
else
{
count = asCollection.Count;
}
packer.PackArrayHeader( count );
foreach ( var item in asEnumerable )
{
this.ItemSerializer.PackTo( packer, item );
}
}
}
#endif // UNITY
}