Skip to content

Commit bf77e1a

Browse files
committed
Refactoring
1 parent 7a2810a commit bf77e1a

File tree

7 files changed

+43
-60
lines changed

7 files changed

+43
-60
lines changed

Shared/MessagePack/ConverterContext.cs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -10,11 +10,6 @@
1010
using nanoFramework.MessagePack.Extensions;
1111
using nanoFramework.MessagePack.Exceptions;
1212
using System.Diagnostics.CodeAnalysis;
13-
14-
15-
16-
17-
1813
#if !NANOFRAMEWORK_1_0
1914
using System.Collections.Concurrent;
2015
#endif
@@ -112,6 +107,11 @@ public static void Replace(Type type, IConverter converter)
112107
Add(type, converter);
113108
}
114109

110+
/// <summary>
111+
/// Return converter by type
112+
/// </summary>
113+
/// <param name="type">Type from converter</param>
114+
/// <returns>Converter interface <see cref="IConverter"/></returns>
115115
public static IConverter GetConverter(Type type)
116116
{
117117
if (type == typeof(object))

Shared/MessagePack/Converters/IConverter.cs

Lines changed: 13 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -3,18 +3,24 @@
33

44
namespace nanoFramework.MessagePack.Converters
55
{
6-
// public interface IConverter<T> : IConverter
7-
// {
8-
//#nullable enable
9-
// void Write(T? value, [NotNull] IMessagePackWriter writer);
10-
// new T? Read([NotNull] IMessagePackReader reader);
11-
// }
12-
6+
/// <summary>
7+
/// Converter interface
8+
/// </summary>
139
public interface IConverter
1410
{
11+
/// <summary>
12+
/// Write object in to target MessagePack stream
13+
/// </summary>
14+
/// <param name="value">Source object</param>
15+
/// <param name="writer">Target MessagePack stream</param>
1516
#nullable enable
1617
void Write(object? value, [NotNull] IMessagePackWriter writer);
1718

19+
/// <summary>
20+
/// Read object from MessagePack stream
21+
/// </summary>
22+
/// <param name="reader">MessagePack stream</param>
23+
/// <returns>Readied object</returns>
1824
object? Read([NotNull] IMessagePackReader reader);
1925
}
2026
}

Shared/MessagePack/DataTypes.cs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,8 @@
11
namespace nanoFramework.MessagePack
22
{
3+
/// <summary>
4+
/// Supporting MessagePack types
5+
/// </summary>
36
public enum DataTypes : byte
47
{
58
Null = 0xc0,

Shared/MessagePack/Extensions/MemberInfoExtension.cs

Lines changed: 0 additions & 25 deletions
This file was deleted.

Shared/MessagePack/MessagePack.projitems

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,6 @@
3939
<Compile Include="$(MSBuildThisFileDirectory)Exceptions\ConverterNotFoundException.cs" />
4040
<Compile Include="$(MSBuildThisFileDirectory)Exceptions\SerializationException.cs" />
4141
<Compile Include="$(MSBuildThisFileDirectory)Extensions\DataTypesExtension.cs" />
42-
<Compile Include="$(MSBuildThisFileDirectory)Extensions\MemberInfoExtension.cs" />
4342
<Compile Include="$(MSBuildThisFileDirectory)Extensions\NumberConverterHelper.cs" />
4443
<Compile Include="$(MSBuildThisFileDirectory)MessagePackSerializer.cs" />
4544
<Compile Include="$(MSBuildThisFileDirectory)Extensions\ObjectTokenHelper.cs" />

Shared/MessagePack/MessagePackSerializer.cs

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -33,18 +33,6 @@ public static void Serialize(object data, MemoryStream stream)
3333
Serialize(data, writer);
3434
}
3535

36-
private static void Serialize(object data, IMessagePackWriter writer)
37-
{
38-
var type = data.GetType();
39-
40-
var converter = ConverterContext.GetConverter(type);
41-
42-
if (converter != null)
43-
converter.Write(data, writer);
44-
else
45-
ConverterContext.SerializeObject(type, data, writer);
46-
}
47-
4836
/// <summary>
4937
/// Deserialize MessagePack data in to object
5038
/// </summary>
@@ -79,6 +67,18 @@ private static void Serialize(object data, IMessagePackWriter writer)
7967
else
8068
return ConverterContext.DeserializeObject(type, reader);
8169
}
82-
70+
71+
private static void Serialize(object data, IMessagePackWriter writer)
72+
{
73+
var type = data.GetType();
74+
75+
var converter = ConverterContext.GetConverter(type);
76+
77+
if (converter != null)
78+
converter.Write(data, writer);
79+
else
80+
ConverterContext.SerializeObject(type, data, writer);
81+
}
82+
8383
}
8484
}

Shared/MessagePack/Stream/BaseReader.cs

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -148,6 +148,14 @@ public void SkipToken()
148148

149149
throw new ArgumentOutOfRangeException();
150150
}
151+
#nullable enable
152+
public ArraySegment? ReadToken()
153+
{
154+
StartTokenGathering();
155+
SkipToken();
156+
var gatheredBytes = StopTokenGathering();
157+
return gatheredBytes;
158+
}
151159

152160
private void SkipMapItems(uint count)
153161
{
@@ -190,17 +198,9 @@ protected static bool TryGetLengthFromFixMap(DataTypes type, out uint length)
190198
length = type - DataTypes.FixMap;
191199
return type.GetHighBits(4) == DataTypes.FixMap.GetHighBits(4);
192200
}
193-
#nullable enable
201+
194202
protected abstract ArraySegment? StopTokenGathering();
195203

196204
protected abstract void StartTokenGathering();
197-
198-
public ArraySegment? ReadToken()
199-
{
200-
StartTokenGathering();
201-
SkipToken();
202-
var gatheredBytes = StopTokenGathering();
203-
return gatheredBytes;
204-
}
205205
}
206206
}

0 commit comments

Comments
 (0)