- Learning Concurrency in Kotlin
- Miguel Angel Castiblanco Torres
- 307字
- 2021-08-05 10:46:48
Creating a coroutine to call a service
Now it's a good time to add a call to a service. To start with something simple, we will use Java's DocumentBuilder to call an RSS feed for us. First, we will add a variable to hold the DocumentBuilderFactory below where we put the dispatcher:
private val dispatcher = newSingleThreadContext(name = "ServiceCall")
private val factory = DocumentBuilderFactory.newInstance()
The second step is to create a function that will do the actual call:
private fun fetchRssHeadlines(): List<String> {
val builder = factory.newDocumentBuilder()
val xml = builder.parse("https://www.npr.org/rss/rss.php?id=1001")
return emptyList()
}
Notice how the function is, for now, returning an empty list of strings after calling the feed. The idea is to implement this function so that it returns the headlines of the given feed. But, first let's call this function as part of the coroutine defined previously:
launch(dispatcher) {
fetchRssHeadlines()
}
Now, the fetching of the headlines will happen in the thread of dispatcher. The next step is to actually read the body of the response and return the headlines. For this example, we are going to parse the XML by hand – as opposed to using some library to do the parsing:
private fun fetchRssHeadlines(): List<String> {
val builder = factory.newDocumentBuilder()
val xml = builder.parse("https://www.npr.org/rss/rss.php?id=1001")
val news = xml.getElementsByTagName("channel").item(0)
return (0 until news.childNodes.length)
.map { news.childNodes.item(it) }
.filter { Node.ELEMENT_NODE == it.nodeType }
.map { it as Element }
.filter { "item" == it.tagName }
.map {
it.getElementsByTagName("title").item(0).textContent
}
}
This code is simply going through all elements in the XML and filtering out everything but the title of each article in the feed.
Now that the function is actually returning the information, we can receive it in preparation to display it on the user interface:
launch(dispatcher) {
val headlines = fetchRssHeadlines()
}
- OpenDaylight Cookbook
- ThinkPHP 5實戰
- GeoServer Cookbook
- PaaS程序設計
- Windows系統管理與服務配置
- PhoneGap Mobile Application Development Cookbook
- Scala編程(第5版)
- Emotional Intelligence for IT Professionals
- OpenCV 3.0 Computer Vision with Java
- Hands-On Dependency Injection in Go
- 深入淺出 HTTPS:從原理到實戰
- Flask開發Web搜索引擎入門與實戰
- Spring Boot 2+Thymeleaf企業應用實戰
- C語言程序設計
- Getting Started with Hazelcast