Skip to content

Commit a32f85f

Browse files
OguzYuukselOguz Yuksel
andauthored
update dependencies (#24)
Co-authored-by: Oguz Yuksel <[email protected]>
1 parent 9b72dc2 commit a32f85f

File tree

9 files changed

+14
-45
lines changed

9 files changed

+14
-45
lines changed

Package.resolved

Lines changed: 0 additions & 25 deletions
This file was deleted.

Package.swift

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
// swift-tools-version:5.2
1+
// swift-tools-version:5.9
22

33
import PackageDescription
44

@@ -10,8 +10,8 @@ let package = Package(
1010
.library(name: "CombineWampDynamic", type: .dynamic, targets: ["CombineWamp"])
1111
],
1212
dependencies: [
13-
.package(url: "https://github.com/teufelaudio/CombineWebSocket.git", .upToNextMajor(from: "0.1.1")),
14-
.package(url: "https://github.com/teufelaudio/FoundationExtensions.git", .upToNextMajor(from: "1.1.1"))
13+
.package(url: "https://github.com/teufelaudio/CombineWebSocket.git", from: "0.1.0"),
14+
.package(url: "https://github.com/teufelaudio/FoundationExtensions.git", from: "2.0.0")
1515
],
1616
targets: [
1717
.target(

Sources/CombineWamp/PeerWorkflow/Client/WampCallee.swift

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ public struct WampCallee: WampCalleeProtocol {
3838

3939
return Empty().eraseToAnyPublisher()
4040
}
41-
.promise(onEmpty: { .failure(.sessionIsNotValid) })
41+
.eraseToPromise(onEmpty: .failure(.sessionIsNotValid))
4242
}
4343
.map { registeredMessage -> AnyPublisher<(invocation: Message.Invocation, responder: ([ElementType]) -> Publishers.Promise<Void, ModuleError>), ModuleError> in
4444
messageBus
@@ -100,8 +100,7 @@ public struct WampCallee: WampCalleeProtocol {
100100

101101
return Empty().eraseToAnyPublisher()
102102
}
103-
.promise(onEmpty: { .failure(.sessionIsNotValid) })
103+
.eraseToPromise(onEmpty: .failure(.sessionIsNotValid))
104104
}
105-
.promise
106105
}
107106
}

Sources/CombineWamp/PeerWorkflow/Client/WampCaller.swift

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -37,8 +37,7 @@ public struct WampCaller: WampCallerProtocol {
3737

3838
return Empty().eraseToAnyPublisher()
3939
}
40-
.promise(onEmpty: { .failure(.sessionIsNotValid) })
40+
.eraseToPromise(onEmpty: .failure(.sessionIsNotValid))
4141
}
42-
.promise
4342
}
4443
}

Sources/CombineWamp/PeerWorkflow/Client/WampClient.swift

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,7 @@ public struct WampClient {
103103
return .init(error: ModuleError.wampError(.protocolViolation))
104104
}
105105
}
106-
.promise(onEmpty: { .failure(.sessionIsNotValid) })
106+
.eraseToPromise(onEmpty: .failure(.sessionIsNotValid))
107107
}
108108
}
109109

@@ -137,7 +137,7 @@ public struct WampClient {
137137
}
138138
.first()
139139
.setFailureType(to: ModuleError.self)
140-
.promise(onEmpty: { .failure(.sessionIsNotValid) })
140+
.eraseToPromise(onEmpty: .failure(.sessionIsNotValid))
141141
}
142142
}
143143

Sources/CombineWamp/PeerWorkflow/Client/WampPublisher.swift

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -37,9 +37,8 @@ public struct WampPublisher: WampPublisherProtocol {
3737

3838
return Empty().eraseToAnyPublisher()
3939
}
40-
.promise(onEmpty: { .failure(.sessionIsNotValid) })
40+
.eraseToPromise(onEmpty: .failure(.sessionIsNotValid))
4141
}
42-
.promise
4342
}
4443

4544
public func publishWithoutAck(topic: URI, positionalArguments: [ElementType]? = nil, namedArguments: [String : ElementType]? = nil)

Sources/CombineWamp/PeerWorkflow/Client/WampSubscriber.swift

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ public struct WampSubscriber: WampSubscriberProtocol {
3838

3939
return Empty().eraseToAnyPublisher()
4040
}
41-
.promise(onEmpty: { .failure(.sessionIsNotValid) })
41+
.eraseToPromise(onEmpty: .failure(.sessionIsNotValid))
4242
}
4343
.map { subscribedMessage -> AnyPublisher<Message.Event, ModuleError> in
4444
messageBus
@@ -90,8 +90,7 @@ public struct WampSubscriber: WampSubscriberProtocol {
9090

9191
return Empty().eraseToAnyPublisher()
9292
}
93-
.promise(onEmpty: { .failure(.sessionIsNotValid) })
93+
.eraseToPromise(onEmpty: .failure(.sessionIsNotValid))
9494
}
95-
.promise
9695
}
9796
}

Sources/CombineWamp/PeerWorkflow/Connection/WampSession.swift

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -76,9 +76,9 @@ public class WampSession: Cancellable {
7676
return self.transport
7777
.send(message: message)
7878
.mapError { _ in ModuleError.wampError(.networkFailure) }
79-
.promise
79+
8080
}
81-
.promise
81+
8282
}
8383

8484
public func cancel() {

Sources/CombineWamp/PeerWorkflow/Connection/WampTransport.swift

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -66,9 +66,7 @@ extension WampTransport {
6666
}.eraseToAnyPublisher()
6767
},
6868
send: { message in
69-
webSocket
70-
.send(message)
71-
.promise
69+
Publishers.Promise(webSocket.send(message))
7270
}
7371
)
7472
}

0 commit comments

Comments
 (0)