Skip to content

Commit 2a49674

Browse files
stebetlukebakken
authored andcommitted
Getting rid of an unnecessary NetworkBinaryWriter in the socket handler.
1 parent e9390a0 commit 2a49674

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

projects/client/RabbitMQ.Client/src/client/impl/SocketFrameHandler.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ class SocketFrameHandler : IFrameHandler
7878
private int _writeableStateTimeoutMicroSeconds;
7979
private readonly NetworkBinaryReader _reader;
8080
private readonly ITcpClient _socket;
81-
private readonly NetworkBinaryWriter _writer;
81+
private readonly Stream _writer;
8282
private readonly object _semaphore = new object();
8383
private readonly object _streamLock = new object();
8484
private bool _closed;
@@ -122,7 +122,7 @@ public SocketFrameHandler(AmqpTcpEndpoint endpoint,
122122
}
123123
}
124124
_reader = new NetworkBinaryReader(new BufferedStream(netstream, _socket.Client.ReceiveBufferSize));
125-
_writer = new NetworkBinaryWriter(netstream);
125+
_writer = netstream;
126126

127127
WriteTimeout = writeTimeout;
128128
}

0 commit comments

Comments
 (0)