This repository was archived by the owner on Mar 21, 2025. It is now read-only.
File tree 1 file changed +3
-5
lines changed
samples/AspNetCoreSseServer
1 file changed +3
-5
lines changed Original file line number Diff line number Diff line change @@ -10,19 +10,17 @@ namespace AspNetCoreSseServer;
10
10
11
11
public class SseServerStreamTransport ( Stream sseResponseStream ) : ITransport
12
12
{
13
- [ ThreadStatic ]
14
- private static Utf8JsonWriter ? _jsonWriter ;
15
-
16
13
private readonly Channel < IJsonRpcMessage > _incomingChannel = CreateSingleItemChannel < IJsonRpcMessage > ( ) ;
17
14
private readonly Channel < SseItem < IJsonRpcMessage ? > > _outgoingSseChannel = CreateSingleItemChannel < SseItem < IJsonRpcMessage ? > > ( ) ;
18
15
19
16
private Task ? _sseWriteTask ;
17
+ private Utf8JsonWriter ? _jsonWriter ;
20
18
21
19
public bool IsConnected => _sseWriteTask ? . IsCompleted == false ;
22
20
23
21
public Task RunAsync ( CancellationToken cancellationToken )
24
22
{
25
- static void WriteJsonRpcMessageToBuffer ( SseItem < IJsonRpcMessage ? > item , IBufferWriter < byte > writer )
23
+ void WriteJsonRpcMessageToBuffer ( SseItem < IJsonRpcMessage ? > item , IBufferWriter < byte > writer )
26
24
{
27
25
if ( item . EventType == "endpoint" )
28
26
{
@@ -70,7 +68,7 @@ private static Channel<T> CreateSingleItemChannel<T>() =>
70
68
SingleWriter = false ,
71
69
} ) ;
72
70
73
- private static Utf8JsonWriter GetUtf8JsonWriter ( IBufferWriter < byte > writer )
71
+ private Utf8JsonWriter GetUtf8JsonWriter ( IBufferWriter < byte > writer )
74
72
{
75
73
if ( _jsonWriter is null )
76
74
{
You can’t perform that action at this time.
0 commit comments