in AWSAppSyncTestCommon/MockConnectionProvider/MockConnectionProvider.swift [39:65]
func write(_ message: AppSyncMessage) {
guard validConnection else {
listener?(.error(ConnectionProviderError.connection))
return
}
guard isConnected else {
listener?(.connection(.notConnected))
return
}
switch message.messageType {
case .connectionInit:
print("")
case .subscribe:
let response = AppSyncResponse(id: message.id,
payload: [:],
type: .subscriptionAck)
listener?(.data(response))
case .unsubscribe:
let response = AppSyncResponse(id: message.id,
payload: [:],
type: .unsubscriptionAck)
listener?(.data(response))
}
}