Skip to content

Commit 11f6f81

Browse files
committed
for read decision: check the actual connection
1 parent a075a0b commit 11f6f81

3 files changed

Lines changed: 5 additions & 1 deletion

File tree

src/StackExchange.Redis/BufferedStreamWriter.Sync.cs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,8 @@ namespace StackExchange.Redis;
77

88
internal sealed class BufferedSyncStreamWriter : CycleBufferStreamWriter
99
{
10+
public override bool IsSync => true;
11+
1012
private readonly TaskCompletionSource<bool> _completion = new(TaskCreationOptions.RunContinuationsAsynchronously);
1113

1214
public BufferedSyncStreamWriter(Stream target, CancellationToken cancellationToken = default)

src/StackExchange.Redis/BufferedStreamWriter.cs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,8 @@ public enum WriteMode
2222
Pipe,
2323
}
2424

25+
public virtual bool IsSync => false;
26+
2527
public static BufferedStreamWriter Create(WriteMode mode, ConnectionType connectionType, Stream target, CancellationToken cancellationToken)
2628
{
2729
// TODO: change to Async when debugged

src/StackExchange.Redis/PhysicalConnection.Read.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ internal void StartReading(CancellationToken cancellation = default)
4141
cancellation = InputCancel;
4242
}
4343

44-
if (WriteMode is BufferedStreamWriter.WriteMode.Sync)
44+
if (_output is { IsSync: true })
4545
{
4646
StartReadingSync(this, cancellation);
4747
static void StartReadingSync(PhysicalConnection conn, CancellationToken cancellation)

0 commit comments

Comments
 (0)