Skip to content

Commit c2e0cdb

Browse files
committed
replaced m_BufferSize field with call to FastBufferWriter.GetWriteSize()
1 parent e16ffb3 commit c2e0cdb

File tree

2 files changed

+4
-7
lines changed

2 files changed

+4
-7
lines changed

Assets/BossRoom/Scripts/Shared/Infrastructure/PubSub/MessageChannelDIExtensions.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,9 +6,9 @@ public static void BindMessageChannelInstance<TMessage>(this DIScope scope)
66
{
77
scope.BindInstanceAsSingle<MessageChannel<TMessage>, IPublisher<TMessage>, ISubscriber<TMessage>, IMessageChannel<TMessage>>(new MessageChannel<TMessage>());
88
}
9-
public static void BindNetworkedMessageChannelInstance<TMessage>(this DIScope scope, int bufferSize) where TMessage : unmanaged
9+
public static void BindNetworkedMessageChannelInstance<TMessage>(this DIScope scope) where TMessage : unmanaged
1010
{
11-
scope.BindInstanceAsSingle<NetworkedMessageChannel<TMessage>, IPublisher<TMessage>, ISubscriber<TMessage>, IMessageChannel<TMessage>>(new NetworkedMessageChannel<TMessage>(bufferSize));
11+
scope.BindInstanceAsSingle<NetworkedMessageChannel<TMessage>, IPublisher<TMessage>, ISubscriber<TMessage>, IMessageChannel<TMessage>>(new NetworkedMessageChannel<TMessage>());
1212
}
1313

1414
public static void BindBufferedMessageChannelInstance<TMessage>(this DIScope scope)

Assets/BossRoom/Scripts/Shared/Infrastructure/PubSub/NetworkedMessageChannel.cs

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -16,14 +16,11 @@ public class NetworkedMessageChannel<T> : MessageChannel<T> where T : unmanaged
1616
{
1717
string m_Name;
1818

19-
int m_BufferSize;
20-
2119
bool m_HasRegisteredHandler;
2220

23-
public NetworkedMessageChannel(int bufferSize)
21+
public NetworkedMessageChannel()
2422
{
2523
m_Name = $"{nameof(T)}NetworkMessageChannel";
26-
m_BufferSize = bufferSize;
2724
}
2825

2926
~NetworkedMessageChannel()
@@ -76,7 +73,7 @@ public override void Publish(T message)
7673

7774
void SendMessageThroughNetwork(T message)
7875
{
79-
var writer = new FastBufferWriter(m_BufferSize, Allocator.Temp);
76+
var writer = new FastBufferWriter(FastBufferWriter.GetWriteSize<T>(), Allocator.Temp);
8077
writer.WriteValueSafe(message);
8178
NetworkManager.Singleton.CustomMessagingManager.SendNamedMessageToAll(m_Name, writer);
8279
}

0 commit comments

Comments
 (0)