@@ -175,6 +175,7 @@ class FakeApiClient : ApiClient {
175
175
MessageApiOuterClass .SortDirection .SORT_DIRECTION_ASCENDING -> {
176
176
result = result.reversed().toMutableList()
177
177
}
178
+
178
179
else -> Unit
179
180
}
180
181
}
@@ -191,6 +192,7 @@ class FakeApiClient : ApiClient {
191
192
published.addAll(envelopes)
192
193
return PublishResponse .newBuilder().build()
193
194
}
195
+
194
196
override suspend fun subscribe (request : Flow <MessageApiOuterClass .SubscribeRequest >): Flow <MessageApiOuterClass .Envelope > {
195
197
val env = stream.counts().first()
196
198
@@ -205,7 +207,9 @@ data class Fixtures(
205
207
val aliceAccount : PrivateKeyBuilder ,
206
208
val bobAccount : PrivateKeyBuilder ,
207
209
val caroAccount : PrivateKeyBuilder ,
208
- val clientOptions : ClientOptions ? = null
210
+ val clientOptions : ClientOptions ? = ClientOptions (
211
+ ClientOptions .Api (XMTPEnvironment .LOCAL , isSecure = false)
212
+ ),
209
213
) {
210
214
var fakeApiClient: FakeApiClient = FakeApiClient ()
211
215
var alice: PrivateKey = aliceAccount.getPrivateKey()
@@ -214,6 +218,7 @@ data class Fixtures(
214
218
var bobClient: Client = Client ().create(account = bobAccount, options = clientOptions)
215
219
var caro: PrivateKey = caroAccount.getPrivateKey()
216
220
var caroClient: Client = Client ().create(account = caroAccount, options = clientOptions)
221
+
217
222
constructor (clientOptions: ClientOptions ? ) : this (
218
223
aliceAccount = PrivateKeyBuilder (),
219
224
bobAccount = PrivateKeyBuilder (),
0 commit comments