Add imports to discovery scala snippets (#29220)

This commit is contained in:
Arnout Engelen 2020-06-11 12:31:41 +02:00 committed by GitHub
parent f1b6c6a1c6
commit eb1cb6ebd9
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -5,7 +5,6 @@
package doc.akka.discovery
import akka.actor.ActorSystem
import akka.discovery.{ Discovery, Lookup, ServiceDiscovery }
import scala.concurrent.Future
import scala.concurrent.duration._
@ -14,18 +13,25 @@ import scala.concurrent.ExecutionContext.Implicits.global
object CompileOnlySpec {
//#loading
import akka.discovery.Discovery
val system = ActorSystem()
val serviceDiscovery = Discovery(system).discovery
//#loading
//#basic
import akka.discovery.Lookup
serviceDiscovery.lookup(Lookup("akka.io"), 1.second)
// Convenience for a Lookup with only a serviceName
serviceDiscovery.lookup("akka.io", 1.second)
//#basic
//#full
val lookup: Future[ServiceDiscovery.Resolved] =
import akka.discovery.Lookup
import akka.discovery.ServiceDiscovery.Resolved
val lookup: Future[Resolved] =
serviceDiscovery.lookup(Lookup("akka.io").withPortName("remoting").withProtocol("tcp"), 1.second)
//#full