Skip to content

Commit 2ca5142

Browse files
Update swift-nio dependency (#39)
Motivation: This PR closes #23. Modifications: * changed `swift-nio` dependency from `branch: main` to `from: 2.43.1` * updated code to conform to new `NIOAsyncSequenceProducer` interface
1 parent ecbd5d9 commit 2ca5142

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

Package.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ let package = Package(
3030
),
3131
],
3232
dependencies: [
33-
.package(url: "https://github.com/apple/swift-nio.git", branch: "main"),
33+
.package(url: "https://github.com/apple/swift-nio.git", from: "2.43.1"),
3434
.package(url: "https://github.com/apple/swift-log.git", from: "1.0.0"),
3535
],
3636
targets: [

Sources/SwiftKafka/KafkaConsumer.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,7 @@ public final class KafkaConsumer {
120120
self?.close()
121121
}
122122
let messagesSourceAndSequence = NIOAsyncSequenceProducer.makeSequence(
123-
of: Element.self,
123+
elementType: Element.self,
124124
backPressureStrategy: backpressureStrategy,
125125
delegate: messagesSequenceDelegate
126126
)

Sources/SwiftKafka/KafkaProducer.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,7 @@ public actor KafkaProducer {
110110
// This is due to the fact that deiniting the sequence is used as part of a trigger to
111111
// terminate the underlying source.
112112
let acknowledgementsSourceAndSequence = NIOAsyncSequenceProducer.makeSequence(
113-
of: Acknowledgement.self,
113+
elementType: Acknowledgement.self,
114114
backPressureStrategy: NoBackPressure(),
115115
delegate: NoDelegate()
116116
)

0 commit comments

Comments
 (0)