File tree Expand file tree Collapse file tree 1 file changed +6
-6
lines changed
Sources/OpenAPIRuntime/EventStreams Expand file tree Collapse file tree 1 file changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -199,14 +199,14 @@ extension ServerSentEventsDeserializationSequence.Iterator {
199
199
buffer. removeFirst ( )
200
200
if line. isEmpty {
201
201
// Dispatch the accumulated event.
202
- state = . accumulatingEvent( . init( ) , buffer: buffer)
203
202
// If the last character of data is a newline, strip it.
204
203
if event. data? . hasSuffix ( " \n " ) ?? false { event. data? . removeLast ( ) }
205
-
206
- if let data = event. data {
207
- if !predicate( ArraySlice ( Data ( data. utf8) ) ) {
208
- return . returnNil
209
- }
204
+
205
+ state = . accumulatingEvent( . init( ) , buffer: buffer)
206
+
207
+ if let data = event. data, !predicate( ArraySlice ( data. utf8) ) {
208
+ state = . finished
209
+ return . returnNil
210
210
}
211
211
return . emitEvent( event)
212
212
}
You can’t perform that action at this time.
0 commit comments