Use scala ops for concurrent operations