File tree Expand file tree Collapse file tree 1 file changed +0
-6
lines changed
Sources/OpenAPIRuntime/EventStreams Expand file tree Collapse file tree 1 file changed +0
-6
lines changed Original file line number Diff line number Diff line change @@ -58,19 +58,13 @@ extension ServerSentEventsDeserializationSequence: AsyncSequence {
58
58
/// The state machine of the iterator.
59
59
var stateMachine : StateMachine
60
60
61
- /// A closure that determines whether the given byte chunk should be forwarded to the consumer.
62
- /// - Parameter: A byte chunk.
63
- /// - Returns: `true` if the byte chunk should be forwarded, `false` if this byte chunk is the terminating sequence.
64
- let predicate : ( ArraySlice < UInt8 > ) -> Bool
65
-
66
61
/// Creates a new sequence.
67
62
/// - Parameters:
68
63
/// - upstream: The upstream sequence of arbitrary byte chunks.
69
64
/// - while: A closure that determines whether the given byte chunk should be forwarded to the consumer.
70
65
init ( upstream: UpstreamIterator , while predicate: @escaping ( ( ArraySlice < UInt8 > ) -> Bool ) ) {
71
66
self . upstream = upstream
72
67
self . stateMachine = . init( while: predicate)
73
- self . predicate = predicate
74
68
}
75
69
76
70
/// Asynchronously advances to the next element and returns it, or ends the
You can’t perform that action at this time.
0 commit comments