Skip to content

Commit 3f77b4e

Browse files
authored
Update README.md [skip ci]
1 parent 94cae98 commit 3f77b4e

File tree

1 file changed

+6
-7
lines changed

1 file changed

+6
-7
lines changed

README.md

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ Seq internally limits the resources a query is allowed to consume. The query met
5252
The snippet below demonstrates lazily enumerating through results to retrieve the complete set.
5353

5454
```csharp
55-
var resultSet = await connection.Events.EnumerateAsync(
55+
var resultSet = connection.Events.EnumerateAsync(
5656
filter: "Environment = 'Test'",
5757
render: true,
5858
count: 1000);
@@ -65,20 +65,19 @@ All methods that retrieve events require a `count`. The API client defaults this
6565

6666
### Streaming events
6767

68-
Seq 3.4 provides live streaming of events matching a filter and/or set of signals.
68+
Seq provides live streaming of events matching a filter and/or set of signals.
6969

7070
```csharp
7171
var filter = "@Level = 'Error'";
7272

73-
using (var stream = await connection.Events.StreamAsync<JObject>(filter: filter))
74-
using (stream.Select(jObject => LogEventReader.ReadFromJObject(jObject))
75-
.Subscribe(evt => Log.Write(evt)))
73+
await foreach (var evt in connection.Events.StreamAsync<JObject>(filter: filter, clef: true))
7674
{
77-
await stream;
75+
var logEvent = LogEventReader.ReadFromString(evt);
76+
Log.Write(logEvent);
7877
}
7978
```
8079

81-
The `Events.StreamAsync()` method returns a hot `IObservable<T>` over a _WebSocket_. The observable will keep producing events until either it's disposed, or the server is shut down.
80+
`Events.StreamAsync()` method returns `IAsyncEnumerable<T>` over a _WebSocket_. The enumerator will keep producing events until either it's disposed, or the server is shut down.
8281

8382
Seq streams the events in [compact JSON format](https://github.com/serilog/serilog-formatting-compact), which the Seq API client library can deserialize into JSON.NET `JObjects` for consumption.
8483

0 commit comments

Comments
 (0)